2 回答
TA貢獻(xiàn)1842條經(jīng)驗(yàn) 獲得超22個(gè)贊
您需要的不僅僅是一個(gè) WaitGroup 來(lái)協(xié)調(diào)此例程??纯催@個(gè)圖案:
func main() {
const size = 100
var (
wg sync.WaitGroup
a [size]int
)
// Fill array a with all ones
for i := 0; i < size; i++ {
go func(x int) {
wg.Add(1)
a[x] = 1
wg.Done()
}(i)
}
wg.Wait()
fmt.Println(a)
}
每個(gè)工作人員在開(kāi)始工作之前將自己添加到 WaitGroup 中,然后在完成后將自己刪除。 你看到問(wèn)題了嗎?嘗試自己運(yùn)行幾次并查看輸出。
wg.Wait()僅當(dāng)您在調(diào)用所有預(yù)期的方法之后wg.Add(x)調(diào)用它時(shí)才有效。由于wg.Add(1)它們?cè)?goroutine 中,沒(méi)有任何其他同步,我們不確定到 時(shí)添加了多少mainworker wg.Wait()。例如,有可能在 100 名工人中,有 50 人都打電話(huà)了wg.Add(1),然后wg.Done()在剩下的 50 人做任何事情之前。因此,wg.Wait()在 50 名工人仍未完成時(shí)繼續(xù)進(jìn)行。這一切就是說(shuō)wg.Add(x)必須同步!
var barrier sync.WaitGroup
barrier.Add(workers)
for k := 0; k < workers; k++ {
go sumWorkerFunc(k, a, &barrier)
}
在這種情況下,Add是同步的,因?yàn)樗l(fā)生在工作人員開(kāi)始執(zhí)行之前。
br.Done()
br.Wait()
br.Add(1)
讓你所有的工人都打電話(huà)不一定有問(wèn)題Wait,問(wèn)題Add是不同步。您不能在此處使用 WaitGroup 來(lái)同步自身。您需要一些額外的功能(另一個(gè) WaitGroup、一個(gè)鎖、一個(gè)通道等)來(lái)在輪次之間創(chuàng)建跨工作線程的同步。
這是我能想到的最簡(jiǎn)單的解決方案,它使每一輪都有一個(gè) WaitGroup:
func main() {
const (
workers = 3
rounds = 5
)
work := func(i int, roundWgs []sync.WaitGroup) {
for r := 0; r < rounds; r++ {
// This is the "work" we do each round
fmt.Printf("round: %v, worker %v\n", r, i)
// We are finished the current round, and will wait for the group.
roundWgs[r].Done()
roundWgs[r].Wait()
}
}
// Each round of work has it's own WaitGroup, in which each worker must finish.
var roundWgs = make([]sync.WaitGroup, rounds)
for i := 0; i < rounds; i++ {
roundWgs[i].Add(workers)
}
// wg is our outermost WaitGroup, which waits until all work is done.
var wg sync.WaitGroup
wg.Add(workers)
for i := 0; i < workers; i++ {
go func(j int) {
defer wg.Done()
work(j, roundWgs)
}(i)
}
wg.Wait()
}
輸出:
round: 0, worker 2
round: 0, worker 0
round: 0, worker 1
round: 1, worker 1
round: 1, worker 0
round: 1, worker 2
round: 2, worker 2
round: 2, worker 1
round: 2, worker 0
round: 3, worker 0
round: 3, worker 2
round: 3, worker 1
round: 4, worker 1
round: 4, worker 2
round: 4, worker 0
同樣,Adds 是同步的,因?yàn)樗鼈兌及l(fā)生在任何 worker 開(kāi)始之前。
TA貢獻(xiàn)1836條經(jīng)驗(yàn) 獲得超5個(gè)贊
我認(rèn)為你正在嘗試做的更像是一個(gè)共享內(nèi)存場(chǎng)景。最好不要延遲等待,而是將其放在啟動(dòng) goroutine 的循環(huán)之后。并且您應(yīng)該使用互斥鎖來(lái)確?;コ狻?/p>
而且我認(rèn)為這個(gè)問(wèn)題的順序無(wú)關(guān)緊要。
- 2 回答
- 0 關(guān)注
- 211 瀏覽
添加回答
舉報(bào)
