[Перевод] Ox: Императивный подход к параллельной потоковой обработке данных

Джерело:
Хабрахабр / Захабренные / Тематические / Посты

Дата публікації:
16/12/2024 16:49

Постійна адреса новини:
http://www.vsinovyny.com/11535329

[Перевод] Ox: Императивный подход к параллельной потоковой обработке данных

16/12/2024 16:49 // Хабрахабр / Захабренные / Тематические / Посты

Ox, библиотека Scala для безопасного параллелизма и отказоустойчивости в императивном стиле (direct‑style) на JVM, получила новую реализацию параллельной потоковой обработки данных. Она позволяет определять конвейеры обработки данных с помощью функционального API, императивного API или сразу обоих вариантов одновременно.

Потоковая обработка данных в Ox была и раньше: предыдущая реализация была основана исключительно на каналах. Хоть она и работала, но все‑таки имела свои недостатки: каждый этап преобразования вводил асинхронную границу. В некоторых ситуациях это может быть неэффективно: если вы оперируете всего лишь несколькими неблокирующими и не требующими больших затрат CPU этапами, такими как .filter, .mapStateful или .interleave, асинхронные границы просто не нужны. Следовательно, такой подход приводил к избыточному параллелизму.

» Читати повністю

«	Наступна новина з архіву Достройка энергоблоков №3 и №4 Хмельницкой АЭС предусмотрена энергетической стратегией до 2050 года – эксперт	Попередня новина з архіву Ask HN: Examples of Agentic LLM Systems in Production?	»