Дизайн-сервис для исполнителей одного потребителя Mullti

Question

У меня есть java.util.BlockingQueue, который полон POJO, который должен обслуживаться ExecutorService. Эта очередь должна обслуживаться одним потоком, но будет перенесена из нескольких потоков одновременно.

В прошлом, я написал мое решение, чтобы выглядеть немного, как это, но я действительно презираю:

executorService.execute(new Runnable() { 

    @Override 
    public void run() { 
     while (true) { 
      try { 
       POJO job = blockingQueue.take(); 
       servicePOJO(job); 
      } catch (InterruptedException e) { 
       break; 
      } 
     } 
    } 
}); 

Есть ли лучший способ написания этого, или это оптимальный способ Делать это? Причина, по которой мне не нравится делать это, состоит в том, что, если мне нужно добавить несколько потребителей, мне нужно запустить выше в цикле с размером фактического пула потоков.

Answer 1

Я бы использовал ExecutorService с заданием на объект.

public <POJO> void asyncServicePOJO(final POJO pojo) { 
    executorService.execute(new Runnable() { 
     @Override 
     public void run() { 
      servicePOJO(pojo); 
     } 
    }); 
} 

Нет необходимости в дополнительной очереди.