假設我有一大串字符串,我想對它們進行排序,除了通常的 sort.Sort 和 sort.Slice 等之外,我想使用多個核心來加快速度。因此,在閱讀大列表時,我將字符串添加到 2 個不同的切片中,即以 am 和 nz 開頭的字符串(為了論證)。同時,我啟動了多個 go 例程來讀取字符串切片通道,然后這些字符串切片將對其自己的子列表進行排序。到目前為止,一切都很好,“可能”并行處理列表,因此我的排序時間實際上減半了。偉大的。現(xiàn)在我的問題是如何將結(jié)果返回到主 goroutine?最初每個 goroutine 有 2 個通道,一個用于傳入的未排序列表,另一個用于排序列表。是的,它有效......但使用了太多內(nèi)存(嘿,給出我正在為這個測試修改的數(shù)據(jù)量,這可能不是不合理的)。但后來我意識到,在通道上傳遞切片實際上只是傳遞引用,所以我實際上不需要傳遞任何東西。不必將生成的排序列表放入回程的通道中,顯然對記憶的負擔要小得多,但它(對我來說)有味道。這意味著我可以讓其中一個 Goroutine 進行排序,同時主 Goroutine(理論上)可以操作同一個列表。只要遵守紀律,這就不會成為問題,但顯然仍然是一個問題。Go 中是否有一種普遍接受的最佳實踐,即引用不應該作為輸入從一個 goroutine 傳遞到另一個 goroutine...但是可以通過通道返回生成引用數(shù)據(jù)的 goroutine (因為 goroutine 然后會停止使用參考)。在有人說之前,是的,我知道我不必通過渠道等傳遞這些信息,但這正是我正在修改并讓我思考的情況。我知道,手又長又波浪。這是顯示上述內(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貢獻1818條經(jīng)驗 獲得超11個贊
傳遞指針、切片或映射沒有任何問題。只要同步對共享變量的訪問,就可以傳遞一個指針并在發(fā)送 Goroutine 中繼續(xù)使用它。對于數(shù)組或大型結(jié)構(gòu)體等大型對象,傳遞指針通常是避免昂貴的復制的邏輯做法。此外,避免傳遞指針意味著避免傳遞切片和映射,或任何包含切片、映射或指向其他結(jié)構(gòu)的指針的內(nèi)容。
如您所知,這里實際上并不需要通道,只需在構(gòu)建切片后啟動 goroutine,然后直接傳遞切片即可。
go sortWordsList(words1) go sortWordsList(words2)
或者:
go sort.Strings(words1) go sort.Strings(words2)
- 1 回答
- 0 關注
- 115 瀏覽
添加回答
舉報
0/150
提交
取消