Задача планирования

Question

В моем проекте у меня есть две JMS-очереди, одна Очередь данных и одна Бизнес-очередь.несколько потоков считывают данные из этих двух очередей и отправляют их в сетку нескольких механизмов.В Grid есть несколько движков, которые могут выполнять задачи параллельно как синхронно, так и асинхронно.

Постановка проблемы: события из бизнес-очереди должны иметь приоритет над очередью данных в сетке.

Эта проблема может быть решена многими способами, но использование ресурсов должно быть оптимальным, и, если возможно, не произойдет голодание события в очереди данных.

Одно простое решение: поддерживать счетчик, увеличивать, если бизнессобытие приходит и уменьшается, если бизнес-событие обрабатывается в сетке.Если приходит событие данных, нужно подождать, пока счетчик не достигнет нуля (или максимального количества двигателей в сетке).Sthng может быть сделано, чтобы остановить голод.

какой лучше soln, который оптимально использует движки сетки, и может ли быть оптимальным использование java-потоков?

Answer 1

Вы пробовали это в темах читателя:

while(reading from any queue)
{
    while (there are messages in business queue)
    {
        process a business queue message.
    }

    process one data queue message.
}