How to wait for all threads to finish, using ExecutorService?

Basically on an ExecutorService you call shutdown() and then awaitTermination():

ExecutorService taskExecutor = Executors.newFixedThreadPool(4);
while(...) {
  taskExecutor.execute(new MyTask());
}
taskExecutor.shutdown();
try {
  taskExecutor.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
} catch (InterruptedException e) {
  ...
}

Related Contents:

  1. ExecutorService that interrupts tasks after a timeout
  2. Executors.newCachedThreadPool() versus Executors.newFixedThreadPool()
  3. What are the advantages of using an ExecutorService?
  4. Java’s Fork/Join vs ExecutorService – when to use which?
  5. Impossible to make a cached thread pool with a size limit?
  6. ThreadPoolExecutor Block When its Queue Is Full?
  7. What’s the difference between Thread start() and Runnable run()
  8. Why must wait() always be in synchronized block
  9. Why is creating a Thread said to be expensive?
  10. ExecutorService, how to wait for all tasks to finish
  11. What is the difference between Thread.start() and Thread.run()?
  12. Handling exceptions from Java ExecutorService tasks
  13. Synchronization vs Lock
  14. How to wait for a number of threads to complete?
  15. How to properly shutdown java ExecutorService
  16. Volatile vs Static in Java
  17. Are static variables shared between threads?
  18. Prime numbers by Eratosthenes quicker sequential than concurrently?
  19. How do synchronized static methods work in Java and can I use it for loading Hibernate entities?
  20. When would you call java’s thread.run() instead of thread.start()?
  21. Why use a ReentrantLock if one can use synchronized(this)?
  22. Choose between ExecutorService’s submit and ExecutorService’s execute
  23. Parallel streams, collectors and thread safety
  24. Java Executors: how can I set task priority?
  25. What are the main uses of yield(), and how does it differ from join() and interrupt()?
  26. How to properly use Java Executor?
  27. How to shutdown an ExecutorService?
  28. Volatile variable in Java
  29. Which concurrent Queue implementation should I use in Java?
  30. What is the JVM thread scheduling algorithm?
  31. What’s a monitor in Java?
  32. Turning an ExecutorService to daemon in Java
  33. Why should I use concurrent characteristic in parallel stream with collect?
  34. What is mutex and semaphore in Java ? What is the main difference?
  35. CountDownLatch vs. Semaphore
  36. FixedThreadPool vs CachedThreadPool: the lesser of two evils
  37. WAITING at sun.misc.Unsafe.park(Native Method)
  38. Constructor synchronization in Java
  39. Parallel execution of directed acyclic graph of tasks
  40. When should I use a CompletionService over an ExecutorService?
  41. Java : Does wait() release lock from synchronized block
  42. Java: ExecutorService that blocks on submission after a certain queue size [duplicate]
  43. Simplest and understandable example of volatile keyword in Java
  44. How to use invokeAll() to let all thread pool do their task?
  45. Programmatic deadlock detection in java
  46. When should we use Java’s Thread over Executor?
  47. Java: How to use Thread.join
  48. What is adaptive spinning w.r.t lock acquisition?
  49. How can I wrap a method so that I can kill its execution if it exceeds a specified timeout?
  50. Does Java have support for multicore processors/parallel processing?

Leave a Comment