Comment définir le compteur Java CountDownLatch et la barrière de cycle CyclicBarrier

Définition

CountDownLatch : une aide à la synchronisation qui permet à un ou plusieurs threads d'attendre la fin d'un ensemble d'opérations effectuées dans d'autres threads.

CyclicBarrier : une aide à la synchronisation qui permet à un ensemble de threads d'attendre chacun autre pour atteindre un point de barrière commun.

Ce qui précède est la définition officielle d'Oracle. En termes simples

CountDownLatch : Compteur qui permet à un ou plusieurs threads d'attendre qu'un ensemble d'opérations effectuées dans d'autres threads soit terminé.

CyclicBarrier : Cyclic Barrier, qui permet à un groupe de threads d'attendre les uns les autres pour atteindre un point de barrière commun.

Difference

• CountDownLatch est membre d'AQS (AbstractQueuedSynchronizer), mais CyclicBarrier ne l'est pas.

• Dans le scénario d'utilisation de CountDownLatch, il existe deux types de threads, l'un est le thread d'attente qui appelle la méthode wait() et l'autre est le thread d'exploitation qui appelle la méthode countDownl(). Dans le contexte de CyclicBarrier, tous les threads sont des threads qui s'attendent les uns les autres et sont du même type.

• CountDownLatch est un décompte, qui ne peut pas être réinitialisé après une décrémentation. CyclicBarrier est un décompte, qui est automatiquement réinitialisé après une incrémentation.

Exemple CountDownLatch

Créez deux groupes de threads, un groupe attend l'autre. groupe pour terminer l'exécution avant de continuer. le thread d'accumulation pour terminer l'exécution, puis le thread principal Afficher le résultat cumulé

CountDownLatch countDownLatch = new CountDownLatch(5);
ExecutorService executorService = Executors.newCachedThreadPool();
for (int i = 0; i < 5; i++) {
    executorService.execute(() -> {
        countDownLatch.countDown();
        System.out.println("run..");
    });
}
for (int i = 0; i < 3; i++) {  //我们要等上面执行完成才继续
    executorService.execute(() -> {
        try {
            countDownLatch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("await..");
    });
}
executorService.shutdown();

Print:

997


3 Simuler la concurrence

public class ThreadUnsafeExample {
    private int cnt = 0;
    public void add() {
        cnt++;
    }
    public int get() {
        return cnt;
    }
    public static void main(String[] args) throws InterruptedException {
        final int threadSize = 1000;
        ThreadUnsafeExample example = new ThreadUnsafeExample();
        final CountDownLatch countDownLatch = new CountDownLatch(threadSize);
        ExecutorService executorService = Executors.newCachedThreadPool();
        for (int i = 0; i < threadSize; i++) {
            executorService.execute(() -> {
                example.add();
                countDownLatch.countDown();
            });
        }
        countDownLatch.await();
        executorService.shutdown();
        System.out.println(example.get());
    }
}

Print:

【pool-2-thread-2】Démarrer l'exécution&hellip ;…

【pool-2-thread-5 】Démarrer l'exécution...

【pool-2-thread-3】Démarrer l'exécution...

【pool-2-thread-1】Démarrer l'exécution... Exécution. ..

Exemple de barrière cyclique

Tous les threads s'attendent jusqu'à ce qu'une certaine étape soit terminée avant de continuer l'exécution

ExecutorService executorService = Executors.newCachedThreadPool();
        CountDownLatch countDownLatch = new CountDownLatch(1);
        for (int i = 0; i < 5; i++) {
            executorService.submit( () -> {
                try {
                    countDownLatch.await();
                    System.out.println("【" + Thread.currentThread().getName() + "】开始执行……");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
        }
        Thread.sleep(2000);
        countDownLatch.countDown();//开始并发
        executorService.shutdown();

Imprimer :

avant..

avant..

avant..
après..
après . .
après..

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!