在 Java 中 CyclicBarrier和 CountDownLatch有什么区别

CyclicBarrier和CountDownLatch都是Java中的多线程同步工具，它们的主要区别在于它们的作用和使用方式。

CyclicBarrier用于在多个线程之间进行同步，等待所有线程都准备好之后再执行后续的操作。它的作用类似于一个屏障，当所有的线程都到达该屏障时，它们才能继续执行后续的操作。CyclicBarrier可以被重复使用，每次调用await()方法都会使当前线程进入等待状态，直到所有线程都到达屏障。

CountDownLatch也用于线程同步，但它的作用是等待一组事件发生之后再执行后续的操作。它的作用类似于倒计时器，当倒计时器的值变为0时，等待的所有线程才能继续执行后续的操作。CountDownLatch不能被重复使用，一旦倒计时器的值变为0，它就不能再次被使用。

因此，CyclicBarrier适合在多个线程之间进行同步，等待所有线程都准备好之后再执行后续的操作，而CountDownLatch适合等待一组事件发生之后再执行后续的操作。

相关问题

在 Java 中 CyclicBarrier和 CountDownLatch有什么区别？

CyclicBarrier和CountDownLatch都是Java中的同步工具类，可以在多个线程之间协调和同步。

CyclicBarrier的作用是让一组线程到达一个同步点后再同时继续执行。它的构造函数可以指定线程数和到达同步点后的操作。当所有线程都调用await()方法后，CyclicBarrier会执行构造函数中指定的操作。CyclicBarrier可以重复使用。

CountDownLatch的作用是让一个线程或多个线程等待其他线程完成操作后再继续执行。CountDownLatch的构造函数可以指定计数器的初始值，每个线程完成操作后都会调用countDown()方法，计数器的值会减1。当计数器的值减到0时，等待线程会被唤醒。CountDownLatch不能重复使用。

因此，CyclicBarrier适用于一组线程需要等待其他线程执行完毕后再同时继续执行的场景，而CountDownLatch适用于一个或多个线程需要等待其他线程完成操作后再继续执行的场景。

CyclicBarrier和CountDownLatch有什么区别？

CyclicBarrier和CountDownLatch是Java中的两个并发工具类，它们有以下区别：

1. 作用对象不同：CyclicBarrier作用于线程，要等待固定数量的线程都到达栅栏位置才能继续执行；而CountDownLatch作用于事件，只需等待数字倒数到0。

2. 执行动作不同：CyclicBarrier可以设置执行动作barrierAction，当所有线程都到达栅栏位置时，会执行这个动作；而CountDownLatch没有这个功能。

下面是一个使用CyclicBarrier和CountDownLatch的示例：

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

public class BarrierExample {
    public static void main(String[] args) {
        int threadCount = 3;
        
        // 使用CyclicBarrier
        CyclicBarrier cyclicBarrier = new CyclicBarrier(threadCount, () -> {
            System.out.println("所有线程都到达栅栏位置，开始执行barrierAction");
        });
        
        for (int i = 0; i < threadCount; i++) {
            new Thread(() -> {
                try {
                    System.out.println(Thread.currentThread().getName() + " 到达栅栏位置");
                    cyclicBarrier.await();
                    System.out.println(Thread.currentThread().getName() + " 继续执行");
                } catch (InterruptedException | BrokenBarrierException e) {
                    e.printStackTrace();
                }
            }).start();
        }
        
        // 使用CountDownLatch
        CountDownLatch countDownLatch = new CountDownLatch(threadCount);
        
        for (int i = 0; i < threadCount; i++) {
            new Thread(() -> {
                try {
                    System.out.println(Thread.currentThread().getName() + " 执行任务");
                    countDownLatch.countDown();
                    countDownLatch.await();
                    System.out.println(Thread.currentThread().getName() + " 继续执行");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }
}