CountDownLatch vs. Semaphore

by

CountDownLatch is frequently used for the exact opposite of your example. Generally, you would have many threads blocking on await() that would all start simultaneously when the countown reached zero.

final CountDownLatch countdown = new CountDownLatch(1);

for (int i = 0; i < 10; ++ i) {
   Thread racecar = new Thread() {    
      public void run() {
         countdown.await(); //all threads waiting
         System.out.println("Vroom!");
      }
   };
   racecar.start();
}
System.out.println("Go");
countdown.countDown();   //all threads start now!

You could also use this as an MPI-style “barrier” that causes all threads to wait for other threads to catch up to a certain point before proceeding.

final CountDownLatch countdown = new CountDownLatch(num_thread);

for (int i = 0; i < num_thread; ++ i) {
   Thread t= new Thread() {    
      public void run() {
         doSomething();
         countdown.countDown();
         System.out.printf("Waiting on %d other threads.",countdown.getCount());
         countdown.await();     //waits until everyone reaches this point
         finish();
      }
   };
   t.start();
}

That all said, the CountDownLatch can safely be used in the manner you’ve shown in your example.

More Related Contents:

  1. What is mutex and semaphore in Java ? What is the main difference?
  2. How to wait for all threads to finish, using ExecutorService?
  3. Is there an advantage to use a Synchronized Method instead of a Synchronized Block?
  4. Why is creating a Thread said to be expensive?
  5. When and how should I use a ThreadLocal variable?
  6. What is the difference between Thread.start() and Thread.run()?
  7. Java Wait and Notify: IllegalMonitorStateException
  8. Are static variables shared between threads?
  9. How do synchronized static methods work in Java and can I use it for loading Hibernate entities?
  10. Is iterating ConcurrentHashMap values thread safe?
  11. Why use a ReentrantLock if one can use synchronized(this)?
  12. How is CountDownLatch used in Java Multithreading?
  13. Is it safe to get values from a java.util.HashMap from multiple threads (no modification)?
  14. How do I implement task prioritization using an ExecutorService in Java 5?
  15. Constructor synchronization in Java
  16. Parallel execution of directed acyclic graph of tasks
  17. Javafx: Difference between javafx.concurent and Platform.runLater?
  18. Instruction reordering & happens-before relationship [duplicate]
  19. Programmatic deadlock detection in java
  20. When should we use Java’s Thread over Executor?
  21. Run Java Threads sequentially
  22. WAITING at sun.misc.Unsafe.park(Native Method)
  23. ThreadPoolExecutor Block When its Queue Is Full?
  24. Java : Does wait() release lock from synchronized block
  25. How Threadpool re-use Threads and how it works
  26. Concurrent JUnit testing
  27. Handling Exceptions for ThreadPoolExecutor
  28. LinkedBlockingQueue vs ConcurrentLinkedQueue
  29. Setting Ideal size of Thread Pool [duplicate]
  30. Does a breakpoint halt all threads?

Leave a Comment