Java多线程并发编程，CountDownLatch与CyclicBarrier的区别实例

原创亦凉 2024-11-21 15:06 105阅读 0赞

`CountDownLatch`和`CyclicBarrier`都是Java中用于管理多个线程同步的工具。它们的主要区别在于：

1. **操作方式：**
   - CountDownLatch：当一个或多个等待它的线程被信号量减少到零时，这些线程就会被唤醒。
   - CyclicBarrier：所有等待它的线程都将在一个共享的屏障处等待，直到最后一个线程到达屏障。

2. **使用场景：**
   - CountDownLatch：通常用于一个大型任务由多个子任务共同完成的情况。每个子任务完成后会调用`countDown()`方法减少计数器。
   - CyclicBarrier：适合于一组需要同时开始执行的线程，当所有线程都通过屏障时，这些线程将自动等待，直到再次被信号唤醒。

实例：

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

public class MultiThreadExample {
    public static void main(String[] args) throws InterruptedException {
        // 使用CountDownLatch
        CountDownLatch countDownLatch = new CountDownLatch(3);
        
        for (int i = 0; i < 3; i++) {
            new Thread(() -> {
                System.out.println("Task " + i + " started...");
                
                try {
                    countDownLatch.countDown();
                    // 等待子任务完成
                    countDownLatch.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                
                System.out.println("Task " + i + " finished successfully!");
            }).start();
        }

// 使用CyclicBarrier
        CyclicBarrier cyclicBarrier = new CyclicBarrier(3, System.out::println));

for (int i = 0; i < 3; i++) {
            new Thread(() -> {
                try {
                    cyclicBarrier.await();
                    // 等待所有线程通过屏障
                    cyclicBarrier.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                
                System.out.println("Task " + i + " finished successfully!");
            }).start();
        }
    }
}
```

上述示例中，`CountDownLatch`用于控制子任务的执行顺序，而`CyclicBarrier`则用于控制线程的执行顺序，当所有线程都通过屏障时，这些线程将自动等待。