问题描述
我使用projectreactor以reactive的方式用Java开发我的个人项目。让我们在下面的图片上看到：
在我的设计中，有一些发布者线程想要将消息发布到通量或通过通量，并且有一些订阅者处理消息。现在，订户可能太慢了。因此，我需要一些背压机制。而且我知道有一些背压策略，但是没有任何一种策略可以满足我的期望。我希望我的发布者仅阻止（等待），直到消息缓冲区（几乎）为空。
那么，如何以反应方式实现它？
解决方法
并行活动可以有两种：线程和参与者（也称为异步过程）。他们在沟通方式上有所不同。助焊剂是演员的交流对象。它不适合连接线程。线程与BlockingQueue连接良好。
