反应堆线程池调度器



我经过了反应堆文档,但是我尚不清楚如何控制在任何给定时间派发多少事件。我想做的是派遣一堆事件,足以让一些消费者忙碌,但随后有一些知道我目前有足够的消费者工作的方法,这样我就不应该再派遣任何活动了。我在想,如果我将调度程序设置为使用ThreadPool,那么在某个时候,它将不会再分配任何线程,并且可能会引发拒绝例外。这样,我可以继续派遣事件,直到收到线程拒绝例外。

是否有某种方法可以这样做,还是我以不应该使用的方式使用反应堆。

一种方法是将积压大小保持在零,这样它将完成您想要的!

最新更新