Ребят, подскажите как разрулить кейс такой. у меня есть два

Question

Ребят, подскажите как разрулить кейс такой. у меня есть два

буферизованных канала, я туда в одной горутине складываю данные, после чего каналы закрываю. и запускаю две горутины на чтение каждого канала и выполнения некоторых операций над этими данными.
тут все ок. но затем в процессе обработки некоторые задачи могут свалиться и их нужно прогнать еще раз. Вернуть в закрытый канал я их не могу, значит нужен еще один канал куда я буду класть те, что упали. так?

Я не могу заранее знать какой буфер делать каналу, так как не знаю сколько данных придется обрабатывать снова, как можно разрулить эту проблему? Может есть какие-то очереди не ограниченные или еще чего?

#backend #go #programming #russian

0

13.10.2019

3 ответов

17 просмотров

Пух

А прогнать ещё раз тем же воркером нельзя?

0

13.10.2019

Andrei 🦉 Sergeev

пусть каждый таск, который вы кладёте в очередь будет иметь метод Commit(), который будет сообщать продьюсеру о том, что таск завершен воркер по окончании обработки таска вызывает этот метод как только у всех тасков был вызван комит, продьюсер закрывает канал и приложение завершается

0

13.10.2019

Пух · Accepted Answer

Пух

Зачем тогда закрывать канал?

0

13.10.2019

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

Ребят, подскажите как разрулить кейс такой. у меня есть два

3 ответов

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