我意识到在反应式编程中阻止它是不可取的.但是,我有一个简单的用例。我有一个生产者比能生产的要快得多的消费者。对于这个现实世界的例子,我估计我只需要一个生产者和4到10个消费者(最多)。我想使用一个有限制的邮箱,这样我的(快速)生产者就不会比它(慢的)用户走得太远。在我以前的(非Akka)实现中,我使用了一个Java BlockingQueue。blocking-bounded-mailbox-example/user/producer/slowConsumerRouter/$a] working on