Идея была такова что отправляет сигнал воркеру чтоб прекратил слушать

Question

Идея была такова что отправляет сигнал воркеру чтоб прекратил слушать

задачи. а на воркере -
select {
case <-w.tasks:
doJob()
case <-w.closeWorkersCh:
return
}
Но наверно надо было просто канал закрывать с задачами. Но как мне узнать что все воркеры отработали?

#backend #go #programming #russian

0

13.10.2020

6 ответов

17 просмотров

Aleksei .Strukov

Если количество воркеров известно, то можно при завершении воркера заставлять его отписывать в канал без буффера, который снаружи читается в цикле c количеством итераций равным количеству воркеров. Правда вопрос, а почему не WaitGroup или Errgroup?

0

13.10.2020

Roman Timofeev

У тебя атомик вжух - и везде inc, а пока ты там селектишь по каналам тебя могли переключить уже много раз

0

13.10.2020

Roman Timofeev

Я бы завел флаг isStopping uint32 и в shutdown его взводил в 1 атомиком, а в воркерах первым делом так же через атомик его проверял

0

13.10.2020

Roman Timofeev

https://play.golang.org/p/fM9F4A_UbUc