public class Test {
private int taskNums = 3;
private volatile CountDownLatch latch = new CountDownLatch(taskNums);
private List<Task> tasks= new ArrayList(3);
private void runTaskBlock(){
executeTasks();
latch.await();
}
private void executeTasks(){
ExecutorService executor = Executors.newFixedThreadPool(taskNums);
for (final Task task : tasks) {
executor.submit(new Runnable() {
@Override
public void run() {
try {
...
} catch (Exception e) {
e.printStackTrace();
} finally {
latch.countDown();
}
}
});
}
executor.shutdown();
}
}