CountDownLatch vs. Semaphore

CountDown latch wird Häufig verwendet, für die das genaue Gegenteil von Ihrem Beispiel. In der Regel, Sie hätte viele threads blockiert "warten ()", die würden alle gleichzeitig zu starten, wenn der countown null erreicht.

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!

Könnte man auch als MPI-Stil "Barriere", die bewirkt, dass alle threads auf andere threads warten zu fangen bis zu einem bestimmten Punkt, bevor Sie fortfahren.

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();
}

Dass alle sagten, der CountDown latch kann sicher verwendet werden, in der Art und Weise, die Sie gezeigt haben, dass in Ihrem Beispiel.

Kurze Zusammenfassung:

1. Semaphore und CountDownLatch dient unterschiedlichen Zwecken.

2. Verwenden Semaphore zu kontrollieren-thread Zugriff auf die Ressource.

3. Verwenden CountDownLatch zu warten, für die Fertigstellung aller threads

Semaphore definition von javadocs:

Einen Semaphore verwaltet eine Reihe von Genehmigungen. Jeder erwerben() blockiert, falls notwendig, bis ein erlauben verfügbar ist, und dann dauert es. Jeder release() fügt eine Genehmigung, potenziell Freigabe einer Sperrung Erwerber.

Jedoch keine eigentliche Genehmigung Objekte verwendet werden; die Semaphore hält nur eine Zählung der Anzahl zur Verfügung und agiert entsprechend.

Wie funktioniert es ?

Semaphoren werden verwendet, um die Anzahl der gleichzeitigen threads, die mit einer Ressource.Diese Ressource kann so etwas wie eine gemeinsame Daten oder einen code-block (kritischen Abschnitt) oder eine Datei.

Den Grafen auf eine Semaphore kann rauf und runter gehen, da verschiedene threads rufen acquire() und release(). Aber an jedem Punkt der Zeit, können Sie nicht mehr die Anzahl der threads größer als Semaphore count.

Semaphore Anwendungsfälle:

1. Begrenzung der gleichzeitigen Zugriffe auf die Festplatte (dies kann töten, der Leistung wegen
   konkurrierende Plattenzugriffe)
2. Thread-Erstellung Begrenzung
3. JDBC connection pooling /Begrenzung
4. Netzwerkverbindung Drosselung
5. Drosselung der CPU-oder Speicher-intensive Aufgaben

Haben Sie einen Blick auf diese Artikel für semaphore verwendet.

CountDownLatch definition von javadocs:

Einer Synchronisierung Hilfe, die erlaubt, dass ein oder mehrere threads warten, bis eine Reihe von Operationen durchgeführt wird, die in anderen threads abgeschlossen ist.

Wie funktioniert es?

CountDownLatch funktioniert, indem ein Zähler initialisiert mit der Zahl der threads, die dekrementiert jedes mal, wenn ein thread seine Ausführung. Wenn der Zähler bei null, es bedeutet, dass alle threads beendet Ihre Ausführung, und der thread-warten auf latch-fortsetzen der Ausführung.

CountDownLatch Anwendungsfälle:

1. Erreichen der Maximalen Parallelität: Manchmal wollen wir beginnen eine Anzahl von
   threads zur gleichen Zeit zu erreichen, die maximale Parallelität
2. Warten N threads abgeschlossen ist, bevor die Ausführung gestartet wird,
3. Deadlock-Erkennung.

Haben Sie einen Blick auf diese Artikel zu verstehen CountDownLatch Konzepte deutlich.

Haben Sie einen Blick auf Fork-Join-Pool an dieser Artikel zu. Es hat einige ähnlichkeiten zu CountDownLatch.

Blick auf die frei verfügbare Quelle, es gibt keine Magie in der Umsetzung der beiden Klassen, so dass Ihre Leistung sollte gleich sein. Wählen Sie die eins, die macht, Ihre Absicht noch deutlicher.