Я просмотрел документацию по реактору, но я не понимаю, как я могу контролировать, сколько событий отправляется в любой момент времени. То, что я хотел бы сделать, - это отправить кучу событий, достаточных для того, чтобы некоторые занятые потребители были заняты, но потом есть способ узнать, что у меня есть достаточное количество пользователей, работающих в данный момент, поэтому я не должен отправлять больше событий. Я думал, если я настрою диспетчера использовать Threadpool, то в какой-то момент он не будет выделять больше потоков и, возможно, выбросит исключение отклонения. Таким образом, я могу продолжать отправлять события до тех пор, пока не получаю исключение отклонения потока.диспетчер пула реакторных потоков
Есть ли способ сделать это, или я использую реактор так, чтобы он не использовался.