我正在學(xué)習(xí) Go 并發(fā)并編寫了強(qiáng)制性工作池示例，其中有 N 個工作和 M 個工作人員（N > M）。我遇到了一個死鎖 ( all goroutines are asleep)，我想不通；但是，我也在死鎖發(fā)生之前得到了預(yù)期的輸出，這讓我更加困惑。有人可以指出我做錯了什么嗎？我的代碼是這樣的：package mainimport ( "fmt" "sync")// A simple worker pool implementation using channels and WaitGroups.// Our workers simply read from a channel of integers from an input// channel and write their squares to an output channel.func addJobs(jobsCh chan<- int, wg *sync.WaitGroup) { // 100 numbers to crunch (jobs) for i := 1; i < 101; i++ { jobsCh <- i } wg.Done()}func worker(jobsCh <-chan int, resultsCh chan<- int, wg2 *sync.WaitGroup) { for num := range jobsCh { resultsCh <- num * num } wg2.Done()}func addWorkers(jobsCh <-chan int, resultsCh chan<- int, wg *sync.WaitGroup) { var wg2 sync.WaitGroup // 10 workers for i := 0; i < 10; i++ { wg2.Add(1) go worker(jobsCh, resultsCh, &wg2) } wg.Done()}func readResults(resultsCh <-chan int, wg *sync.WaitGroup) { for sq := range resultsCh { fmt.Printf("%v ", sq) } wg.Done()}func main() { var wg sync.WaitGroup jobsCh := make(chan int) resultsCh := make(chan int) wg.Add(1) go addJobs(jobsCh, &wg) wg.Add(1) go addWorkers(jobsCh, resultsCh, &wg) wg.Add(1) go readResults(resultsCh, &wg) wg.Wait()}正如預(yù)期的那樣，這會打印數(shù)字的平方（以隨機(jī)順序），但也會遇到死鎖。請參閱此游樂場鏈接。:(
1 回答
九州編程
TA貢獻(xiàn)1785條經(jīng)驗 獲得超4個贊
關(guān)閉jobsCh導(dǎo)致工人退出：
func addJobs(jobsCh chan<- int, wg *sync.WaitGroup) {
// 100 numbers to crunch (jobs)
for i := 1; i < 101; i++ {
jobsCh <- i
}
close(jobsCh) // <-- add this line
wg.Done()
}
工作人員完成后，關(guān)閉resultsCh導(dǎo)致結(jié)果循環(huán)退出：
func addWorkers(jobsCh <-chan int, resultsCh chan<- int, wg *sync.WaitGroup) {
var wg2 sync.WaitGroup
// 10 workers
for i := 0; i < 10; i++ {
wg2.Add(1)
go worker(jobsCh, resultsCh, &wg2)
}
wg2.Wait() // <-- add this line
close(resultsCh) // and this line
wg.Done()
}
- 1 回答
- 0 關(guān)注
- 86 瀏覽
添加回答
舉報
0/150
提交
取消