программ продолжают выполнение хотя все latch.countdown() называется

Question

У меня есть эта простая схема:

int parallelism = 4; //4 tasks 
ExecutorService executor = Executors.newCachedThreadPool(); 
CountDownLatch latch = new CountDownLatch(parallelism); 

for(int i=0;i<parallelism;i++){ 
    executor.execute(new MyTask()); 
} 

latch.await(); 
System.out.println("done"); 

Где Task просто вызывает

public void run(){ 
     System.out.println("working"); 
     latch.countDown(); 
} 

Даже если исполнение дает мне:

working 
working 
working 
working 
done 

общая программа продолжает выполнять! Как так?

Answer 1

Вам необходимо закрыть Executor.

ExecutorService executor = Executors.newCachedThreadPool(); 
    // ... 
    executor.shutdown(); 
    while (executor.awaitTermination(1, TimeUnit.SECONDS)) { 
     System.out.println("This is taking too long."); 
    } 

Даже если все ваши runnables завершили Executor держит нити в бассейне. Это то, что удерживает ваш выход. Нить main не выйдет, пока все потоки не-демона не будут завершены.

Также см. Turning an ExecutorService to daemon in Java для другой альтернативы - использование потоков демона Executor.