ExecutorService, стандартный способ постараться не определять задачу для очереди, становящейся слишком полной

Я использую ExecutorService для простоты параллельной многопоточной программы. Возьмите следующий код:

while(xxx) {
    ExecutorService exService = Executors.newFixedThreadPool(NUMBER_THREADS);
    ...  
    Future<..> ... = exService.submit(..);
    ...
}

В моем случае проблема - это submit() не блокируется если все NUMBER_THREADS заняты. Последствие - то, что очередь Задачи становится лавинно рассылаемой многими задачами. Последствие этого, это закрывающее сервис выполнения с ExecutorService.shutdown() берет возрасты (ExecutorService.isTerminated() будет ложь в течение долгого времени). Причина состоит в том, что очередь задачи все еще довольно полна.

На данный момент мое обходное решение должно работать с семафорами для запрещения, чтобы иметь ко многим записям в очереди задачи ExecutorService:

...
Semaphore semaphore=new Semaphore(NUMBER_THREADS);

while(xxx) {
    ExecutorService exService = Executors.newFixedThreadPool(NUMBER_THREADS); 
    ...
    semaphore.aquire();  
    // internally the task calls a finish callback, which invokes semaphore.release()
    // -> now another task is added to queue
    Future<..> ... = exService.submit(..); 
    ...
}

Я уверен, что существует лучшее более инкапсулированное решение?