我浏览了反应堆文档，但我不清楚如何控制在任何给定时间调度的事件数量。我想做的是发送一堆事件，足以让一些消费者忙碌，但有办法知道我目前有足够的消费者在工作，所以我不应该再发送任何事件。我在想如果我将调度程序设置为使用线程池，那么在某些时候它不会分配更多线程并可能抛出拒绝异常。这样，我可以继续调度事件，直到收到线程拒绝异常。
有什么方法可以做到这一点，或者我是否以不应该使用的方式使用反应器。
问问题
464 次
我浏览了反应堆文档，但我不清楚如何控制在任何给定时间调度的事件数量。我想做的是发送一堆事件，足以让一些消费者忙碌，但有办法知道我目前有足够的消费者在工作，所以我不应该再发送任何事件。我在想如果我将调度程序设置为使用线程池，那么在某些时候它不会分配更多线程并可能抛出拒绝异常。这样，我可以继续调度事件，直到收到线程拒绝异常。
有什么方法可以做到这一点，或者我是否以不应该使用的方式使用反应器。