CountDownLatch Classe

Définition

[Android.Runtime.Register("java/util/concurrent/CountDownLatch", DoNotGenerateAcw=true)]
public class CountDownLatch : Java.Lang.Object

[<Android.Runtime.Register("java/util/concurrent/CountDownLatch", DoNotGenerateAcw=true)>]
type CountDownLatch = class
    inherit Object

Héritage

Object

JavaObject

Object

CountDownLatch

Attributs

RegisterAttribute

Remarques

Aide de synchronisation qui permet à un ou plusieurs threads d’attendre qu’un ensemble d’opérations en cours d’exécution dans d’autres threads se termine.

A CountDownLatch est initialisé avec un nombre< d’em>/em< donnés>. Les #await await méthodes bloquent jusqu’à ce que le nombre actuel atteigne zéro en raison d’appels de la #countDown méthode, après quoi tous les threads en attente sont libérés et les appels suivants de #await await retour immédiatement. Il s’agit d’un phénomène d’un coup - le nombre ne peut pas être réinitialisé. Si vous avez besoin d’une version qui réinitialise le nombre, envisagez d’utiliser un CyclicBarrier.

Il CountDownLatch s’agit d’un outil de synchronisation polyvalent et peut être utilisé à plusieurs fins. Un CountDownLatch initialisé avec un nombre d’un sert de verrou simple activé/désactivé, ou de porte : tous les threads appelant attendent #await await à la porte jusqu’à ce qu’il soit ouvert par un thread appelant #countDown. Un CountDownLatch thread initialisé sur <em>N</em> peut être utilisé pour faire attendre un thread jusqu’à ce que <les threads em>N</em> aient terminé une action, ou une action a été effectuée N fois.

Une propriété utile d’un CountDownLatch est qu’il n’exige pas que les threads appelant countDown attendent que le nombre atteigne zéro avant de continuer, il empêche simplement tout thread de continuer après une #await await jusqu’à ce que tous les threads puissent passer.

<b>Exemple d’utilisation :</b> Voici une paire de classes dans lesquelles un groupe de threads de travail utilisent deux latches de compte à rebours : <ul><li Est>un signal de démarrage qui empêche tout worker de continuer jusqu’à ce que le pilote soit prêt à continuer ; <li>Le second est un signal d’achèvement qui permet au conducteur d’attendre que tous les travailleurs aient terminé. </ul>

{@code
            class Driver { // ...
              void main() throws InterruptedException {
                CountDownLatch startSignal = new CountDownLatch(1);
                CountDownLatch doneSignal = new CountDownLatch(N);

                for (int i = 0; i < N; ++i) // create and start threads
                  new Thread(new Worker(startSignal, doneSignal)).start();

                doSomethingElse();            // don't let run yet
                startSignal.countDown();      // let all threads proceed
                doSomethingElse();
                doneSignal.await();           // wait for all to finish
              }
            }

            class Worker implements Runnable {
              private final CountDownLatch startSignal;
              private final CountDownLatch doneSignal;
              Worker(CountDownLatch startSignal, CountDownLatch doneSignal) {
                this.startSignal = startSignal;
                this.doneSignal = doneSignal;
              }
              public void run() {
                try {
                  startSignal.await();
                  doWork();
                  doneSignal.countDown();
                } catch (InterruptedException ex) {} // return;
              }

              void doWork() { ... }
            }}

Une autre utilisation classique consiste à diviser un problème en parties N, à décrire chaque partie avec un Runnable qui exécute cette partie et compte en bas sur le verrou, et met en file d’attente tous les Runnables à un exécuteur. Lorsque toutes les sous-parties sont terminées, le thread de coordination peut passer par await. (Lorsque les threads doivent compter à plusieurs reprises de cette façon, utilisez plutôt un CyclicBarrier.)

{@code
            class Driver2 { // ...
              void main() throws InterruptedException {
                CountDownLatch doneSignal = new CountDownLatch(N);
                Executor e = ...;

                for (int i = 0; i < N; ++i) // create and start threads
                  e.execute(new WorkerRunnable(doneSignal, i));

                doneSignal.await();           // wait for all to finish
              }
            }

            class WorkerRunnable implements Runnable {
              private final CountDownLatch doneSignal;
              private final int i;
              WorkerRunnable(CountDownLatch doneSignal, int i) {
                this.doneSignal = doneSignal;
                this.i = i;
              }
              public void run() {
                doWork();
                doneSignal.countDown();
              }

              void doWork() { ... }
            }}

Effets de cohérence de la mémoire : jusqu’à ce que le nombre atteigne zéro, les actions d’un thread avant d’appeler countDown()<i>happen-before</i> , suite à un retour réussi d’un thread correspondant await() dans un autre thread.

Ajouté à la version 1.5.

Java documentation pour java.util.concurrent.CountDownLatch.

Les parties de cette page sont des modifications basées sur le travail créé et partagé par Android Open Source et utilisées en fonction des termes décrits dans la Creative Commons 2.5 Attribution License.