Привет. вопрос снова по горутинам) есть код типа такого: receipts := make([]*types.Receipt,

Question

Привет. вопрос снова по горутинам) есть код типа такого: receipts := make([]*types.Receipt,

receiptCount)

errChan := make(chan error)
for i := uint(0); i < receiptCount; i++ {
go func(i uint) {
receipt, err := getReceipt()

if err != nil {
errChan <- err
return
}

receipts[i] = receipt
}(i)
}

if err := <-errChan; err != nil {
return nil, err
}
return receipts, nil

я
хочу сделать так, чтобы если хоть одна ошибка была - делался return nil, err
но если ошибок нету, то код зависает на последнем if'е - оно и понятно, ибо ошибок же нету)

наверно надо сделать отдельный канал типа quit и это в селект обернуть
но как мне узнать, что все горутины были выполнены, но чтобы ещё и errChan слушался парралельно?

#backend #go #programming #russian

0

19.02.2022

8 ответов

24 просмотра

Nikita

Загугли пакет errgroup

0

19.02.2022

nacknime Автор вопроса

Roman 🎄
waitGroup посмотрите

я смотрел) но мне надо одновременно слушать errChan помимо ожидания wg.Wait()

0

19.02.2022

Gaisin Vadim

nacknime
я смотрел) но мне надо одновременно слушать errCha...

errgroup ожидает первую ошибку и завершает контекст

0

19.02.2022

nacknime Автор вопроса

Gaisin Vadim
errgroup ожидает первую ошибку и завершает контекс...

извините за пинг, но чёт не догоняю как сделать через контекст( я то понял, что нужно делать типа select { case <-ctx.Done: return ctx.Err() } но если ошибок не будет, то опять стопор на этом месте)

0

19.02.2022

Геннадий Ковалёв

nacknime
извините за пинг, но чёт не догоняю как сделать че...

А что надо? Подождать, чтобы все завершились?

0

19.02.2022

Andrey Tsvetkov

может вот так? receipts := make([]*types.Receipt, receiptCount) errChan := make(chan error) for i := uint(0); i < receiptCount; i++ { go func(i uint) { receipt, err := getReceipt() if err == nil { receipts[i] = receipt } errChan <- err }(i) } for i := 0; i < receiptCount; i++ { if err := <-errChan; err != nil { return nil, err } } return receipts, nil

0

19.02.2022

nacknime Автор вопроса

Andrey Tsvetkov
может вот так? receipts := make([]*types.Receipt, ...

о, и правда можно так) спасибо, наверное остановлюсь на этом варианте, самый простой оказался)

0

19.02.2022

Roman 🎄 · Accepted Answer

Roman 🎄

waitGroup посмотрите

0

19.02.2022

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

Привет. вопрос снова по горутинам) есть код типа такого: receipts := make([]*types.Receipt,

8 ответов

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