假設(shè)我有一大串字符串,我想對(duì)它們進(jìn)行排序,除了通常的 sort.Sort 和 sort.Slice 等之外,我想使用多個(gè)核心來(lái)加快速度。因此,在閱讀大列表時(shí),我將字符串添加到 2 個(gè)不同的切片中,即以 am 和 nz 開(kāi)頭的字符串(為了論證)。同時(shí),我啟動(dòng)了多個(gè) go 例程來(lái)讀取字符串切片通道,然后這些字符串切片將對(duì)其自己的子列表進(jìn)行排序。到目前為止,一切都很好,“可能”并行處理列表,因此我的排序時(shí)間實(shí)際上減半了。偉大的?,F(xiàn)在我的問(wèn)題是如何將結(jié)果返回到主 goroutine?最初每個(gè) goroutine 有 2 個(gè)通道,一個(gè)用于傳入的未排序列表,另一個(gè)用于排序列表。是的,它有效......但使用了太多內(nèi)存(嘿,給出我正在為這個(gè)測(cè)試修改的數(shù)據(jù)量,這可能不是不合理的)。但后來(lái)我意識(shí)到,在通道上傳遞切片實(shí)際上只是傳遞引用,所以我實(shí)際上不需要傳遞任何東西。不必將生成的排序列表放入回程的通道中,顯然對(duì)記憶的負(fù)擔(dān)要小得多,但它(對(duì)我來(lái)說(shuō))有味道。這意味著我可以讓其中一個(gè) Goroutine 進(jìn)行排序,同時(shí)主 Goroutine(理論上)可以操作同一個(gè)列表。只要遵守紀(jì)律,這就不會(huì)成為問(wèn)題,但顯然仍然是一個(gè)問(wèn)題。Go 中是否有一種普遍接受的最佳實(shí)踐,即引用不應(yīng)該作為輸入從一個(gè) goroutine 傳遞到另一個(gè) goroutine...但是可以通過(guò)通道返回生成引用數(shù)據(jù)的 goroutine (因?yàn)?goroutine 然后會(huì)停止使用參考)。在有人說(shuō)之前,是的,我知道我不必通過(guò)渠道等傳遞這些信息,但這正是我正在修改并讓我思考的情況。我知道,手又長(zhǎng)又波浪。這是顯示上述內(nèi)容的最小代碼子集。package mainimport ( "bufio" "fmt" "os" "sort" "strings" "sync" "time")var wg sync.WaitGroupfunc sortWordsList(id int, ch chan []string ) { l := <- ch sort.Strings(l) wg.Done()}func main() { file, err := os.Open("big.txt") defer file.Close() if err != nil { fmt.Printf("BOOM %s\n", err.Error()) panic(err) } // Start reading from the file with a reader. reader := bufio.NewReader(file) inCh1 := make(chan []string, 1000) inCh2 := make(chan []string, 1000) go sortWordsList(1, inCh1) go sortWordsList(2, inCh2) wg.Add(2) words1 := []string{} words2 := []string{} for { line, err := reader.ReadString('\n') if err != nil { break } sp := strings.Split(line, " ") for _,w := range sp { word := strings.ToLower(w) word = strings.TrimSuffix(word, "\n") if len(word) > 0 { // figure out where to go. // arbitrary split. if word[0] < 'm' { words1 = append(words1, word) } else { words2 = append(words2, word) } } } }
1 回答

慕尼黑8549860
TA貢獻(xiàn)1818條經(jīng)驗(yàn) 獲得超11個(gè)贊
傳遞指針、切片或映射沒(méi)有任何問(wèn)題。只要同步對(duì)共享變量的訪問(wèn),就可以傳遞一個(gè)指針并在發(fā)送 Goroutine 中繼續(xù)使用它。對(duì)于數(shù)組或大型結(jié)構(gòu)體等大型對(duì)象,傳遞指針通常是避免昂貴的復(fù)制的邏輯做法。此外,避免傳遞指針意味著避免傳遞切片和映射,或任何包含切片、映射或指向其他結(jié)構(gòu)的指針的內(nèi)容。
如您所知,這里實(shí)際上并不需要通道,只需在構(gòu)建切片后啟動(dòng) goroutine,然后直接傳遞切片即可。
go sortWordsList(words1) go sortWordsList(words2)
或者:
go sort.Strings(words1) go sort.Strings(words2)
- 1 回答
- 0 關(guān)注
- 133 瀏覽
添加回答
舉報(bào)
0/150
提交
取消