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

Всем привет. хочу реализовать 1 штуку на кор джаве есть входящий поток

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

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

3 ответов

3 просмотра

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

Тут либо строя очередность, либо параллельность. Если обрабатывать параллельно, то нет гарантий очередности завершения задач. Какого рода задачи обрабатываются, можно ли дробить на подзадачи?

Oleksii 🇺🇦- Автор вопроса
Vladimir Solonchenko
Привет, вычитывай батчами(например по 10 штук) зап...

в принципе так и сделал, с небольшими улучшениями, просто оценивал, есть ли варианты получше

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

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

Господа, а что сейчас вообще с рынком труда на делфи происходит? Какова ситуация?
Rꙮman Yankꙮvsky
29
А вообще, что может смущать в самой Julia - бы сказал, что нет единого стандартного подхода по многим моментам, поэтому многое выглядит как "хаки" и произвол. Короче говоря, с...
Viktor G.
2
30500 за редактор? )
Владимир
47
а через ESC-код ?
Alexey Kulakov
29
Чёт не понял, я ж правильной функцией воспользовался чтобы вывести отладочную информацию? но что-то она не ловится
notme
18
У меня есть функция где происходит это: write_bit(buffer, 1); write_bit(buffer, 0); write_bit(buffer, 1); write_bit(buffer, 1); write_bit(buffer, 1); w...
~
14
Добрый день! Скажите пожалуйста, а какие программы вы бы рекомендовали написать для того, чтобы научиться управлять памятью? Можно написать динамический массив, можно связный ...
Филипп
7
Недавно Google Project Zero нашёл багу в SQLite с помощью LLM, о чём достаточно было шумно в определённых интернетах, которые сопровождались рассказами, что скоро всех "ибешни...
Alex Sherbakov
5
Ребят в СИ можно реализовать ООП?
Николай
33
https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_h_common.erl#L174 https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_olp.erl#L76 15 лет назад...
Maksim Lapshin
20
Карта сайта