Как можно сделать, есть массив с тысячами строк с ссылками,

Можно что-то типо такого, поправьте, если что-то неправильно type Cfs struct { wg *sync.WaitGroup cLink string } func WorkerPool(work chan *Cfs, query chan *Cfs) { for { case q := <-query: work <-q } } func CreateWorker(work chan *Cfs) { for { case wrk := <-work: DownloadFile(wrk) (*wrk).wg.Done() } } func main() { workers := 100 queryCh := make(chan *Cfs, workers * 2) workCh := make(chan *Cfs, workers) for i := 0; i < workers; i++ { for j := 0; j < 2; j++ { go WorkerPool(workCh, queryCh) } go CreateWorker(workCh) } wgp := sync.WaitGroup links := []string{"https://123.com","https://456.com"} for link := range links { wgp.Add(1) cfs := Cfs{ wg: wgp, cLink: link, } query<- &cfs } wg.Wait() }

0

23.03.2021

🍗 𝓒ⅇℳℯ𝓗𝓫𝘭Ч🎲 🐲 Автор вопроса

Web
Можно что-то типо такого, поправьте, если что-то н...

wgp := make(sync.WaitGroup) ?

0

23.03.2021

Web

🍗 𝓒ⅇℳℯ𝓗𝓫𝘭Ч🎲 🐲
wgp := make(sync.WaitGroup) ?

Я просто кейс накинул от руки

0

23.03.2021

Aleksei Olshanskiy

Web
Можно что-то типо такого, поправьте, если что-то н...

а теперь внимание вопрос: что будет с селектом если канал закроется? :)

0

23.03.2021

Web

Aleksei Olshanskiy
а теперь внимание вопрос: что будет с селектом есл...

🤡

0

23.03.2021

c

Aleksei Olshanskiy
а теперь внимание вопрос: что будет с селектом есл...

вечный двигатель

0

23.03.2021

Aleksei Olshanskiy

c
вечный двигатель

наоборот, вечная паника)

0

23.03.2021

c

Aleksei Olshanskiy
наоборот, вечная паника)

зависит от селекта

0

23.03.2021

Aleksei Olshanskiy

c
зависит от селекта

я про этот case wrk := <-work: DownloadFile(wrk) (*wrk).wg.Done() }

0

23.03.2021

Alexander Shavelev

Web
Можно что-то типо такого, поправьте, если что-то н...

с семафором, кажется будет намного проще выглядеть

0

23.03.2021

c

Alexander Shavelev
с семафором, кажется будет намного проще выглядеть

с https://pkg.go.dev/golang.org/x/sync/semaphore и https://pkg.go.dev/golang.org/x/sync/errgroup будет ну очень просто

0

23.03.2021

Alexander Shavelev

c
с https://pkg.go.dev/golang.org/x/sync/semaphore ...

в этом же и смысл?! :)

0

23.03.2021

🍗 𝓒ⅇℳℯ𝓗𝓫𝘭Ч🎲 🐲 Автор вопроса

Web
Можно что-то типо такого, поправьте, если что-то н...

Как-то можно таким образом сделать? https://play.golang.org/p/DBSVuAsgNIj поставить на удержание, как поставлено в на 49 строке, в данном коде выполниться только 3 итерации)

0

23.03.2021

Aleksei Olshanskiy

🍗 𝓒ⅇℳℯ𝓗𝓫𝘭Ч🎲 🐲
Как-то можно таким образом сделать? https://play.g...

Вы там запускаете wg.Wait перед wg.Done, идея так се

0

23.03.2021

Web

🍗 𝓒ⅇℳℯ𝓗𝓫𝘭Ч🎲 🐲
Как-то можно таким образом сделать? https://play.g...

Ну когда вы забьёте буфферезированный канал работой, он будет ждать пока место в канале не освободится и в данном случае main Ф-ция заблокируется и будет ждать, пока место освободится. И зачем обязательно по 3 скачивать?

0

24.03.2021

Aleksey Sychev · Accepted Answer

Aleksey Sychev

Канал с фиксированным размером?

0

23.03.2021

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

Как можно сделать, есть массив с тысячами строк с ссылками,

22 ответов

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