AK
я просто про более общий случай
Size: a a a
2020 June 13
AK
ну так если переменная на стэке то под неё и не будет каждый раз выделяться память. вот если ссылка на переменную убегает из цикла, то она и будет выделяться каждый раз, но на куче
всё, был не прав, не до конца прочитал вот это
MW
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()
правильно количество одновременно обрабатываемых запрпосов ограничиваю?
AK
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()
правильно количество одновременно обрабатываемых запрпосов ограничиваю?
да
AK
но я бы чтение из канала тоже в дефер завернул
SN
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()
правильно количество одновременно обрабатываемых запрпосов ограничиваю?
Нет :) у вас будет просто канал с 50 сообщениями максимум в буфере, количество горутин это не ограничит
AK
Нет :) у вас будет просто канал с 50 сообщениями максимум в буфере, количество горутин это не ограничит
это ограничит одновременное выполнение MakeRequest
SN
это ограничит одновременное выполнение MakeRequest
Где ограничение то?
s
Нет :) у вас будет просто канал с 50 сообщениями максимум в буфере, количество горутин это не ограничит
Количество горутин не ограничит. Количество одновременно запрашивающих данные не будет превышать 50, остальные будет ждать
AK
Где ограничение то?
блокировка на запись в канал 51го true
RS
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()
правильно количество одновременно обрабатываемых запрпосов ограничиваю?
во-первых зачем
chan bool если можно chan struct{}?RS
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()
правильно количество одновременно обрабатываемых запрпосов ограничиваю?
во-вторых похоже что нет, неправильно