リアクターのドキュメントを確認しましたが、特定の時点でディスパッチされるイベントの数を制御する方法がわかりません。私がやりたいのは、一部の消費者を忙しくしておくのに十分なイベントを大量にディスパッチすることですが、現時点で十分な数の消費者が働いていることを知る方法があるため、これ以上イベントをディスパッチする必要はありません。ディスパッチャを Threadpool を使用するように設定すると、ある時点でスレッドが割り当てられなくなり、拒否例外がスローされる可能性があると考えていました。このようにして、スレッド拒否例外を受け取るまでイベントをディスパッチし続けることができます。
これを行う方法はありますか、それともリアクターを使用すべきではない方法で使用していますか?