VM
если вы остановите все горутины будет дедлок
Size: a a a
2020 April 02
АП
ну типа делаю запросы по http, вылезает too many connections, хочу сделать паузу на 5-10секунд
Есть какой-то "менджер" коотрый запускает горутины на приходящий реквест. И задача сводится к тому, что он должен узнать об этой ошибке и приостановить запуск новых горутин
АП
То есть, надо выделить такую "надзоную" сущность,
АП
Вам ведь не надо стопать Все горутины. задача не правильно подана
АП
думал может попроще есть вариант, типа вызвать лок sync.Mutex и после него time.Sleep
А по этой фразе вообще не понятно, о чем речь)
АП
Да и само понятие "стоп горутины" - требует уточнения
АП
Либо поставить на паузу какой-то цикл внутри, либо постараться выйти из горутины как можно раньше и чтобы она прибилась
АП
Это все зависит от конкретной вашей задачи.
Z
думал может попроще есть вариант, типа вызвать лок sync.Mutex и после него time.Sleep
Это ерунда. Делайте канал с ограничением
Или используйте golang.org/x/sync/semaphore
// remoteDeleteEmployeeRPC will delete an employee over the network.
func remoteDeleteEmployeeRPC() {
...
}
// sem is a channel that will allow up to 10 concurrent operations.
var sem = make(chan int, 10)
func main() {
for _, employee := range employeeList {
sem <- 1
go func(){
remoteDeleteEmployeeRPC(employee.ID)
<-sem
}()
}
}
Или используйте golang.org/x/sync/semaphore
X
есть waitgroup размером 16 горутин, каждая горутина делает http запрос, бывает в одной из горутин результат too many connections, я хочу сделать так, когда одна горутина получает такой результат - ставятся на паузу все горутины (либо горутина блокировала процесс появления новых горутин и спала (time.sleep) несколько секунд например)
DP
А не используйте пул, и проблема сама решится
АП
"ставятся на паузу все горутины" - это неконкретная фраза то. расшифруйте ее для себя, и станет понятнее