我正在查看有關(guān) goroutines 和 channels 等模式的 goroutines 博客文章。在bounded.go示例中，我看到了這個(gè)：paths, errc := walkFiles(done, root) // Start a fixed number of goroutines to read and digest files. c := make(chan result) // HLc var wg sync.WaitGroup const numDigesters = 20 wg.Add(numDigesters) for i := 0; i < numDigesters; i++ { go func() { digester(done, paths, c) // HLc wg.Done() }() }現(xiàn)在既然每個(gè)消化器都在處理同一個(gè)paths集合，為什么它不重復(fù)同一個(gè)文件兩次呢？
1 回答
慕姐8265434
TA貢獻(xiàn)1813條經(jīng)驗(yàn) 獲得超2個(gè)贊
walkFiles，它沒有在你的問題中轉(zhuǎn)載，但它是理解它的關(guān)鍵，具有以下簽名：
func walkFiles(done <-chan struct{}, root string) (<-chan string, <-chan error)因此，在您引用的代碼中，paths不是“集合”（即切片），而是一個(gè)channel。當(dāng)每個(gè)工作人員從通道中讀取時(shí)，它會(huì)將下一條路徑拉出通道。下一個(gè)從通道接收的工人不會(huì)得到相同的路徑，它會(huì)在那之后得到下一個(gè)。
的所有三個(gè)參數(shù)都是digester通道：
func digester(done <-chan struct{}, paths <-chan string, c chan<- result)done用于向工作人員指示他們應(yīng)該停止，即使仍有工作在排隊(duì)。paths是工人從中接收路徑的工作隊(duì)列。c是工人發(fā)送結(jié)果的渠道。
- 1 回答
- 0 關(guān)注
- 124 瀏覽
添加回答
舉報(bào)
0/150
提交
取消