Java simultanéité: le compte à Rebours loquet vs Cyclique de la barrière

Il y a une autre différence.

Lors de l'utilisation d'un CyclicBarrier, l'hypothèse est que vous spécifiez le nombre de threads en attente de déclenchement de la barrière. Si vous spécifiez 5, vous devez avoir au moins 5 threads d'appeler await().

Lors de l'utilisation d'un CountDownLatch, vous spécifiez le nombre d'appels à countDown() qui fera en sorte que tous les threads en attente d'être libéré. Cela signifie que vous pouvez utiliser un CountDownLatch avec un seul thread.

"Pourquoi voudriez-vous faire cela?", vous pouvez dire. Imaginez que vous êtes à l'aide d'un mystérieux API codé par quelqu'un d'autre qui effectue des rappels. Vous souhaitez qu'un de vos fils d'attendre un certain rappel a été appelé un certain nombre de fois. Vous n'avez aucune idée de qui fils le callback sera appelé. Dans ce cas, un CountDownLatch est parfaite, alors que je ne peux pas penser à une façon de mettre en œuvre ce à l'aide d'un CyclicBarrier (en fait, je peux, mais il implique des délais d'attente... beurk!).

Je souhaite juste que CountDownLatch pourrait être remis à zéro!

OriginalL'auteur Kim

Je pense que la JavaDoc a expliqué les différences explicitement.
La plupart des gens savent que CountDownLatch ne peut pas être remis à zéro, cependant, CyclicBarrier peut. Mais ce n'est pas la seule différence, ou la CyclicBarrier pourrait être renommé ResetbleCountDownLatch.
Nous devrions dire les différences du point de vue de leurs objectifs, qui sont décrits dans la JavaDoc

CountDownLatch: Une synchronisation de l'aide qui permet à un ou plusieurs threads d'attendre jusqu'à ce qu'un ensemble d'opérations effectuées dans d'autres threads complète.

CyclicBarrier: Une synchronisation de l'aide qui permet à un ensemble de threads à tous d'attendre les uns des autres, pour arriver à une barrière point.

Dans countDownLatch, il y a un ou plusieurs threads en attente d'un ensemble de autres threads pour terminer. Dans cette situation, il existe deux types de threads, un type est en attente, un autre type est en train de faire quelque chose, après les finitions de leurs tâches, ils pourraient être en attente ou tout simplement résilié.

Dans CyclicBarrier, il y a un seul type de fils, ils sont en attente pour l'autre, ils sont égaux.

OriginalL'auteur Justin Civi

Cette question a été répondu de manière adéquate déjà, mais je pense que je peux ajouter de la valeur un peu par l'affichage du code.

Pour illustrer le comportement cyclique de la barrière, j'ai fait un exemple de code. Dès que la barrière est à bout, il est automatiquement réinitialiser afin qu'il puisse être utilisé à nouveau (d'où il est "cyclique"). Lorsque vous exécutez le programme, d'observer que les sorties d'impression "Let's play" est déclenché uniquement après la barrière est renversé.

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierCycles {

    static CyclicBarrier barrier;

    public static void main(String[] args) throws InterruptedException {
        barrier = new CyclicBarrier(3); 

        new Worker().start();
        Thread.sleep(1000);
        new Worker().start();
        Thread.sleep(1000);
        new Worker().start();
        Thread.sleep(1000);

        System.out.println("Barrier automatically resets.");

        new Worker().start();
        Thread.sleep(1000);
        new Worker().start();
        Thread.sleep(1000);
        new Worker().start();
    }

}


class Worker extends Thread {
    @Override
    public void run() {
        try {
            CyclicBarrierCycles.barrier.await();
            System.out.println("Let's play.");
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (BrokenBarrierException e) {
            e.printStackTrace();
        }
    }
}

OriginalL'auteur Kevin Lee

Lorsque j'étais étudiant sur les Loquets et cyclicbarriers je suis venu avec cette métaphores.
cyclicbarriers: Imaginez une société dispose d'une salle de réunion. Afin de commencer la réunion, un certain nombre de participants à la réunion ont à venir à la réunion (pour le rendre officiel). le code suivant est celui d'un participant de la réunion (un employé)

class MeetingAtendee implements Runnable {

CyclicBarrier myMeetingQuorumBarrier;

public MeetingAtendee(CyclicBarrier myMileStoneBarrier) {
    this.myMeetingQuorumBarrier = myMileStoneBarrier;
}

@Override
public void run() {
    try {
        System.out.println(Thread.currentThread().getName() + " i joined the meeting ...");
        myMeetingQuorumBarrier.await();
        System.out.println(Thread.currentThread().getName()+" finally meeting stared ...");
    } catch (InterruptedException e) {
        e.printStackTrace();
    } catch (BrokenBarrierException e) {
        System.out.println("Meeting canceled! every body dance <by chic band!>");
    }
 }
}

employé se joint à la réunion, attend que les autres viennent pour démarrer la réunion. aussi, il obtient quitté si la réunion sera annulé 🙂 ensuite, nous avons LE PATRON comment les doses aime pas attendre pour d'autres personnes à se montrer et si il perd son patient, il annule la réunion.

class MeetingAtendeeTheBoss implements Runnable {

CyclicBarrier myMeetingQuorumBarrier;

public MeetingAtendeeTheBoss(CyclicBarrier myMileStoneBarrier) {
    this.myMeetingQuorumBarrier = myMileStoneBarrier;
}

@Override
public void run() {
    try {
        System.out.println(Thread.currentThread().getName() + "I am THE BOSS - i joined the meeting ...");
        //boss dose not like to wait too much!! he/she waits for 2 seconds and we END the meeting
        myMeetingQuorumBarrier.await(1,TimeUnit.SECONDS);
        System.out.println(Thread.currentThread().getName()+" finally meeting stared ...");
    } catch (InterruptedException e) {
        e.printStackTrace();
    } catch (BrokenBarrierException e) {
        System.out.println("what WHO canceled The meeting");
    } catch (TimeoutException e) {
        System.out.println("These employees waste my time!!");
    }
 }
}

Sur une journée normale, employé de venir à la rencontre d'attendre les autres pour se montrer et si certains participants ne viennent pas, ils doivent attendre indéfiniment! dans certains réunion spéciale le patron arrive et il n'aime pas attendre.(5 personnes ont besoin pour démarrer la réunion, mais seulement patron arrive et aussi un passionné de l'employé) afin qu'il annule la réunion (en colère)

CyclicBarrier meetingAtendeeQuorum = new CyclicBarrier(5);
Thread atendeeThread = new Thread(new MeetingAtendee(meetingAtendeeQuorum));
Thread atendeeThreadBoss = new Thread(new MeetingAtendeeTheBoss(meetingAtendeeQuorum));
    atendeeThread.start();
    atendeeThreadBoss.start();

De sortie:

//Thread-1I am THE BOSS - i joined the meeting ...
//Thread-0 i joined the meeting ...
//These employees waste my time!!
//Meeting canceled! every body dance <by chic band!>

Il y a un autre scénario dans lequel un autre outsider thread (un tremblement de terre) annule la réunion (appel de méthode reset). dans ce cas, tous les threads en attente êtes réveillé par une exception.

class NaturalDisasters implements Runnable {

CyclicBarrier someStupidMeetingAtendeeQuorum;

public NaturalDisasters(CyclicBarrier someStupidMeetingAtendeeQuorum) {
    this.someStupidMeetingAtendeeQuorum = someStupidMeetingAtendeeQuorum;
}

void earthQuakeHappening(){
    System.out.println("earth quaking.....");
    someStupidMeetingAtendeeQuorum.reset();
}

@Override
public void run() {
    earthQuakeHappening();
 }
}

l'exécution de code entraînera dans de drôles de sortie:

//Thread-1I am THE BOSS - i joined the meeting ...
//Thread-0 i joined the meeting ...
//earth quaking.....
//what WHO canceled The meeting
//Meeting canceled! every body dance <by chic band!>

Vous pouvez également ajouter un secrétaire à la salle de réunion, si une réunion a eu lieu, elle permettra de documenter chaque chose, mais elle n'est pas une partie de la réunion:

class MeetingSecretary implements Runnable {

@Override
public void run() {
        System.out.println("preparing meeting documents");
        System.out.println("taking notes ...");
 }
}

Loquets: si la colère patron veut organiser une exposition pour la société, les clients, chaque chose doit être prêt (ressources). nous fournissons une liste de choses à faire chaque travailleur (Thread), la dose de son travail et nous vérifions la liste de choses à faire (certains travailleurs pour faire de la peinture, d'autres préparent des sound system ...). lorsque tous les éléments dans la liste "à faire" (ressources), nous pouvons ouvrir les portes aux clients.

public class Visitor implements Runnable{

CountDownLatch exhibitonDoorlatch = null;

public Visitor (CountDownLatch latch) {
    exhibitonDoorlatch  = latch;
}

public void run() {
    try {
        exhibitonDoorlatch .await();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }

    System.out.println("customer visiting exebition");
 }
}

Et les travailleurs comment la préparation de l'exposition:

class Worker implements Runnable {

CountDownLatch myTodoItem = null;

public Worker(CountDownLatch latch) {
    this.myTodoItem = latch;
}

public void run() {
        System.out.println("doing my part of job ...");
        System.out.println("My work is done! remove it from todo list");
        myTodoItem.countDown();
 }
}

    CountDownLatch preperationTodoList = new CountDownLatch(3);

    //exhibition preparation workers  
    Worker      electricalWorker      = new Worker(preperationTodoList);
    Worker      paintingWorker      = new Worker(preperationTodoList);

    //Exhibition Visitors 
    ExhibitionVisitor exhibitionVisitorA = new ExhibitionVisitor(preperationTodoList);
    ExhibitionVisitor exhibitionVisitorB = new ExhibitionVisitor(preperationTodoList);
    ExhibitionVisitor exhibitionVisitorC = new ExhibitionVisitor(preperationTodoList);

    new Thread(electricalWorker).start();
    new Thread(paintingWorker).start();

    new Thread(exhibitionVisitorA).start();
    new Thread(exhibitionVisitorB).start();
    new Thread(exhibitionVisitorC).start();

OriginalL'auteur Mr.Q

Dans le cas de CyclicBarrier, dès que TOUS les threads enfants commence l'appel de la barrière.await(), l'Exécutable est lancé dans la Barrière. La barrière.vous attendent dans chaque enfant thread va prendre différentes longueur de temps à la fin, et ils finissent tous en même temps.

OriginalL'auteur Brandon

Dans CountDownLatch, threads principaux attend les autres threads pour achever leur exécution. Dans CyclicBarrier, threads attendre les uns des autres pour compléter leur exécution.

Vous ne pouvez pas réutiliser les mêmes CountDownLatch exemple une fois le compte à rebours atteint zéro et le verrou est ouvert, sur l'autre main CyclicBarrier peuvent être réutilisés par la réinitialisation de la Barrière, une Fois la barrière est cassée.

OriginalL'auteur V Jo

@Kevin Lee et @Jon, j'ai essayé CyclicBarrier avec l'Option Praticable. Dirait qu'il s'exécute dans le début et après la CyclicBarrier est renversé. Voici le code de sortie et de

statique CyclicBarrier barrière;

    public static void main(String[] args) throws InterruptedException {
        barrier = new CyclicBarrier(3, new Runnable() {
            @Override
            public void run() {
                System.out.println("I run in the beginning and after the CyclicBarrier is tipped");
            }
        });

        new Worker().start();
        Thread.sleep(1000);
        new Worker().start();
        Thread.sleep(1000);
        new Worker().start();
        Thread.sleep(1000);

        System.out.println("Barrier automatically resets.");

        new Worker().start();
        Thread.sleep(1000);
        new Worker().start();
        Thread.sleep(1000);
        new Worker().start();
    }

Sortie

I run in the beginning and after the CyclicBarrier is tipped
Let's play.
Let's play.
Let's play.
Barrier automatically resets.
I run in the beginning and after the CyclicBarrier is tipped
Let's play.
Let's play.
Let's play.

OriginalL'auteur Hari Rao