Rinchin G
Всем привет. Подскажите
у меня есть 2 сервиса: типа один планировщик заданий, второй executor
и есть rabbitmq
планировщик <-> rabbitmq <-> executor
так вот у executor есть ограничение по одновременной обработке задач
планировщик об этом ограничении знает
да, на планировщике я создам newFixedThreadPool(limit)
с него я буду отправлять задания через rabbitmq в executor
но проблемка, если бы я пользовался каким нибудь restTemplate, то в одном потоке бы дожидался результата от executor
и мой FixedThreadPool не отправил бы все задания разом на executor
а здесь же у меня нет ограничения, планировщик просто разом все отправит на rabbit,
как лучше распланировать ограничения количества заданий на rabbit?
А зачем? Очередь же для того и может использоваться, чтобы обработчик не тормозил планировщик, а обрабатывал с доступной ему скоростью. Надо только не забить ее до конца