var concurrency int flag.IntVar(&concurrency, "concurrency", 50, "Max

Question

var concurrency int flag.IntVar(&concurrency, "concurrency", 50, "Max

Concurrent Requests")
// ...

concurrentGoroutines := make(chan bool, concurrency)
var wg sync.WaitGroup

for _, url := range urls {
wg.Add(1)
go func(url string) {
defer wg.Done()
concurrentGoroutines <- true
MakeRequest(url)
<-concurrentGoroutines
}(url)
}

wg.Wait()

правильно количество одновременно обрабатываемых запрпосов ограничиваю?

#backend #go #programming #russian

0

13.06.2020

5 ответов

7 просмотров

Stanislav N.

Нет :) у вас будет просто канал с 50 сообщениями максимум в буфере, количество горутин это не ограничит

0

13.06.2020

Roman Sharkov

во-первых зачем chan bool если можно chan struct{}?

0

13.06.2020

Roman Sharkov

во-вторых похоже что нет, неправильно

0

13.06.2020

Roman Sharkov

https://play.golang.org/p/m5Bl3xq-TF_4 создаём pool горутин и канал, в которую горутина диспетчер пишет работу горутины из пула читают канал работы пока он не закроется таким образом мы не создаём горутины для каждой единицы работы, что хорошо

0

13.06.2020

Andrey Kartashov · Accepted Answer

Andrey Kartashov

да

0

13.06.2020

170 похожих чатов

var concurrency int flag.IntVar(&concurrency, "concurrency", 50, "Max

5 ответов

Похожие вопросы