42-实现自己的异步流

8.13　实现自己的异步流

反应式流定义了一种提供非阻塞背压异步流处理的机制。

反应式流基于以下3个元素：

• 它是信息的发布者；
• 它有一个或多个此信息的订阅者；
• 它提供发布者与消费者之间的订阅处理。

Java 9包含3个接口（ Flow.Publisher、Flow.Subscriber 和 Flow.Subscription ），以及一个实用类 SubmissionPublisher ，以允许我们实现反应式流程序。

本节将介绍如何使用3个接口来实现自己的反应式程序。这时要注意我们将在3个要素之间实现的预期行为。发布者只会将内容发送给请求它们的订阅者，并且会以并行方式执行此操作。但是可以通过修改方法来轻松地修改此行为。