我正在查看有關 goroutines 和 channels 等模式的 goroutines 博客文章。在bounded.go示例中，我看到了這個：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() }() }現在既然每個消化器都在處理同一個paths集合，為什么它不重復同一個文件兩次呢？
1 回答
慕姐8265434
TA貢獻1813條經驗 獲得超2個贊
walkFiles，它沒有在你的問題中轉載，但它是理解它的關鍵，具有以下簽名：
func walkFiles(done <-chan struct{}, root string) (<-chan string, <-chan error)因此，在您引用的代碼中，paths不是“集合”（即切片），而是一個channel。當每個工作人員從通道中讀取時，它會將下一條路徑拉出通道。下一個從通道接收的工人不會得到相同的路徑，它會在那之后得到下一個。
的所有三個參數都是digester通道：
func digester(done <-chan struct{}, paths <-chan string, c chan<- result)done用于向工作人員指示他們應該停止，即使仍有工作在排隊。paths是工人從中接收路徑的工作隊列。c是工人發送結果的渠道。
- 1 回答
- 0 關注
- 120 瀏覽
添加回答
舉報
0/150
提交
取消