но зачем первый канал, в который вы пишете таску, почему не экзекутор передать?)
потому что нельзя выполнять такску одновременно более более чем N раз. dst это небуферизированный канал, из которого читают нужное кол-во воркеров. и если нет свободных воркеров, то в этот канал ничего не запишешь, но если коиент в это время отвалится, то мы не будем плодить лишнюю работу
Обсуждают сегодня