Как выключение CompletionService после завершения в настоящее время выполняются задачи

Question

У меня есть что-то вроде этого:

ExecutorService executor = Executors.newFixedThreadPool(2); 
CompletionService<Boolean> completionService = new ExecutorCompletionService<>(executor); 
int i = 0; 
while (i < 40) { 
    completionService.submit(getTask()); 
    i++; 
} 
executor.shutdown(); 
System.out.println("SHUTDOWN"); 

После вызова shutdown все представленные задачи выполняются. Если я звоню shutdownNow, то в настоящее время выполняются потоки java.lang.InterruptedException.

Есть ли способ подождать выполненные в данный момент задачи, чтобы выполнить и выполнить другие отправленные задачи?

Answer 1

shutdown() позволяет в настоящее время представленные задачи для завершения, но отвергает новые:

Инициирует процедуру завершения работы, в котором выполняются ранее представленные задачи, но никакие новые задачи не будут приняты.

Если вы хотите, чтобы ждать в вашей main нити для исполнителя, чтобы закрыть, вы можете вызвать executor.awaitTermination(long timeout, TimeUnit unit):

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

Если вы хотите, чтобы задачи, которые в настоящее время работает, чтобы закончить, но отбросить те, которые уже представлены в очередь, у вас есть несколько вариантов:

• отменяя Фьючерс с cancel(false):

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

  Возвращает: false, если задача не может быть отменена, как правило, потому что она уже завершена нормально; правда, в противном случае

• оборачивать ваши Runnable/Callable с пользовательской CancellableRunnable/Callable (в зависимости от ваших getTask() возвращается):

  class CancellableRunnable implements Runnable { 
  
      private final AtomicBoolean shouldRun; 
      private final Runnable delegate; 
  
      public CancellableRunnable(AtomicBoolean shouldRun, Runnable delegate) { 
       this.shouldRun = shouldRun; 
       this.delegate = delegate; 
      } 
  
      @Override 
      public void run() { 
       if (shouldRun.get()) { 
        delegate.run(); 
       } 
      } 
  } 
  

  и использования в вашем примере:

  AtomicBoolean shouldRun = new AtomicBoolean(true); 
  while (i < 40) { 
      completionService.submit(new CancellableRunnable(shouldRun, getTask())); 
      i++; 
  } 
  shouldRun.set(false); 
  executor.shutdown(); 
  

Answer 2

Да, после того, как вы позвонили shutdown(), исполнитель не примет никаких новых заданий. Затем вы вызываете awaitTermination(), чтобы дождаться выполнения заданий.

Answer 3

Если все, что вы хотите, это первые два результата, а затем отбросить ot ее задачи, вы можете дождаться завершения первых двух задач, а затем отменить остальные, например, вызывая shutdownNow, если вам больше не нужна служба завершения.

Future<Boolean> result1 = copmletionService.take(); 
Future<Boolean> result2 = copmletionService.take(); 
completionService.shutdownNow();