У меня есть поток, который получает сообщение (список) с 400 записями.Для каждой записи создается сообщение и сохраняется его в очереди MQ (Q-Records-IN).
Существует другой поток, который просматривает очередь (Q-Records-IN), и для каждого сообщения обрабатывает его.В этом случае первый поток очень быстрый, поэтому он быстро создает сообщение 400.
Мне нужно контролировать пропускную способность второго потока, ограничивая его одновременной обработкой максимум 10 сообщений.
Как я могу это сделать?Я действительно ценю любую помощь.
Спасибо