Похожие чаты

Hey guys Assume we have a data pipeline that we are

reading from a file, passing each row to another goroutine through a channel, and that second goroutine does something to those input data and passes them again to another third goroutine. Assuming the order of data passing matters, how can we have multiple goroutines in the second stage reading from the channel?

4 ответов

13 просмотров
AYUB- Автор вопроса

As you may know, we can't guarantee the order of execution when we use goroutines and channels. This is an issue here. How can we have multiple concurrent goroutines reading from a channel and still guarantee the order of the output?

You could implement sth like a tee channel where multiple goroutines are reading from a single source,

Thirteen
You could implement sth like a tee channel where m...

sending the data downstream means you going to lose the ordering so maybe this is not a good idea

AYUB- Автор вопроса
Thirteen
You could implement sth like a tee channel where m...

The reading part is ok. My issue is writing to the output with the same order that it came through

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

Обсуждают сегодня

30500 за редактор? )
Владимир
47
а через ESC-код ?
Alexey Kulakov
29
Anyone knows where there are some instructions or discort about failed bridge transactions ?
Jochem
21
Also, why can’t the community have a vote/ say when it comes to initiatives like buybacks. Isn’t the point of crypto decentralisation? Don’t we deserve input as long term supp...
👨🏽‍🦰
13
Чёт не понял, я ж правильной функцией воспользовался чтобы вывести отладочную информацию? но что-то она не ловится
notme
18
Привет)) уже кажется эту тему перемусолили, но вот я так и не понял. Я сейчас сижу на 27дюймов 2к мониторе. На Актуальной макоси, если я куплю 27д 4к монитор: - будет ли изобр...
Vladislav Piskunov
15
any reference of this implementation?
BitBuddha
29
Hi guys, any problem with Pulsebrige? Trying to transfer from wETH to ETH. First it tells me to connect my metamask "through mobile app" not desktop. Then I did and confirmed ...
Snowflakecrypto
13
У меня есть функция где происходит это: write_bit(buffer, 1); write_bit(buffer, 0); write_bit(buffer, 1); write_bit(buffer, 1); write_bit(buffer, 1); w...
~
13
Страшнейшая правда про списки ЦБ. С первых дней жизни P2P сферы, молодые человеки, начитавшись законодательной базы и "внутренних" документов, решили, что им противостоит сер...
Foxcool
3
Карта сайта