Реактивные потоки - Reactive Streams

Реактивные потоки
изначальный выпуск15 мая 2015; 5 лет назад (2015-05-15)
Стабильный выпуск
1.0.3 / 23 августа 2019; 15 месяцев назад (2019-08-23)
Репозиторийgithub.com/ реактивные потоки/ реактивные потоки-jvm
Написано вJava (Scala, Groovy, Kotlin), .NET.
Интернет сайтреактивные потоки.org

Реактивные потоки это инициатива по предоставлению стандарт за асинхронный потоковая обработка с неблокирующий обратное давление.[1]

Источник

Реактивные потоки стартовали как инициатива в конце 2013 года между инженерами компании Netflix, Основной и Lightbend. Некоторые из самых ранних дискуссий начались в 2013 году между Играть в и Акка команды в Lightbend.[2][3] Lightbend - один из основных разработчиков Reactive Streams.[4] Другие участники включают Красная шляпа, Oracle, Twitter и spray.io.[5]

Цели

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

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

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

Включение в стандарт Java

Спецификация разработана с целью включения в будущем в официальную стандартную библиотеку Java, если она окажется успешной и будет принята достаточным количеством библиотек и поставщиков.

Реактивные потоки предлагалось стать частью Ява 9 пользователем Дуг Ли, лидер JSR 166[7] как новый класс Flow[8] это будет включать интерфейсы, которые в настоящее время предоставляются Reactive Streams.[4][9] После успешного выпуска 1.0 Reactive Streams и растущего внедрения предложение было принято, и Reactive Streams был включен в JDK9 через JEP -266.[9]

Принятие

30 апреля 2015 г. версия 1.0.0 Reactive Streams для JVM был выпущен,[4][5][10] включая Java API,[11] текстовый Технические характеристики,[12] а TCK и примеры реализации. Он поставляется с множеством совместимых реализаций, проверенных TCK для 1.0.0, перечисленных в алфавитном порядке:[10]

Другие реализации включают Кассандра,[22] Elasticsearch,[23] Апач Кафка,[24] Квазар параллельной вселенной,[25] Play Framework,[26] Армерия.[27]

Весна 5 объявляется, что он будет построен на основе Reactor Core, совместимой с Reactive Streams.[28]

Amazon объявила, что ее Веб-сервисы Amazon SDK будет поддерживать Reactive Streams для обеспечения потоковых возможностей в своих клиентских библиотеках в версии 2.0.[29]

Reactive Streams 1.0.1 выпущен 9 августа 2017 года, включая различные улучшения в точности спецификации, улучшения TCK и другие пояснения. Спецификация, а также интерфейсы остались полностью обратно совместимыми с версией 1.0.0, однако были нацелены на упрощение принятия для будущих разработчиков, а также на согласование с некоторыми дополнительными требованиями, установленными OpenJDK.[30]

Порты и влияния

  • Прямой перенос спецификации, интерфейсов и TCK был предоставлен той же рабочей группе для .СЕТЬ Платформа.[31]
  • Когда Эликсир language представил свой потоковый API под названием GenStage, авторы выразили благодарность «[проектам] akka-streams и reactive-streams, которые предоставили нам руководство по реализации обмена по запросу между этапами».[32]

Рекомендации

  1. ^ reactive-streams.org
  2. ^ Путешествие в реактивные потоки
  3. ^ Reactive Streams 1.0.0 интервью
  4. ^ а б c Reactive Streams выпускает первую стабильную версию для JVM
  5. ^ а б Reactive Streams 1.0.0 - новый стандарт реактивной обработки данных
  6. ^ «Реактивные потоки TCK».
  7. ^ jdk9 Классы кандидатов Flow и SubmissionPublisher
  8. ^ java.util.concurrent.Flow
  9. ^ а б JEP 266: Дополнительные обновления параллелизма
  10. ^ а б Reactive Streams 1.0.0 уже здесь!
  11. ^ Java API
  12. ^ Реактивные потоки для спецификации JVM
  13. ^ InfoQ: Реактивные потоки с Akka Streams
  14. ^ Принципы дизайна, лежащие в основе Akka Streams
  15. ^ Java-драйвер MongoDB Reactive Streams
  16. ^ Ratpack: API реактивных потоков
  17. ^ Reactor 2.0.0.RC1 с встроенной поддержкой Reactive Streams уже доступен!
  18. ^ Advanced RxJava: API Reactive-Streams (часть 1)
  19. ^ Тема 3: Реактивные потоки для асинхронного доступа к базе данных в Scala
  20. ^ Slick 3.0.0
  21. ^ Интеграция реактивных потоков Vert.x
  22. ^ Доступ к Кассандре реактивным способом
  23. ^ elastic4s - неблокирующий, типобезопасный клиент DSL и Scala для Elasticsearch
  24. ^ Реактивные потоки для Apache Kafka
  25. ^ Квазар и реактивные потоки
  26. ^ Play Framework - интеграция реактивных потоков (экспериментальная)
  27. ^ Армерия - полностью асинхронная и реактивная
  28. ^ Реактивная пружина
  29. ^ «Объявление о предварительной версии AWS SDK для Java 2.0 для разработчиков».
  30. ^ «Объявление о выпуске Reactive Streams 1.0.1».
  31. ^ "Реактивные потоки .NET".
  32. ^ «Блог Elixir: анонс GenStage».
  •  Эта статья включает текст из www.reactive-streams.org, который выпущен в соответствии с CC0 1.0 Universal (CC0 1.0) Public Domain Dedication.