Java并发工具：CountDownLatch、CyclicBarrier实战

原创ゝ一纸荒年。 2024-10-16 12:57 60阅读 0赞

在Java的并发编程中，CountDownLatch和CyclicBarrier是两种常用的同步工具。下面我们将分别介绍它们的使用方法和实战案例。

1. CountDownLatch

- 作用：CountDownLatch是一个同步工具，它在一个线程执行完后会释放一个计数器，其他等待该计数器为0的线程就会继续执行。

- 使用示例：
```java
import java.util.concurrent.CountDownLatch;

public class CountDownLatchExample {
    private final CountDownLatch countDownLatch = new CountDownLatch(1);

public void countdown() throws InterruptedException {
        System.out.println("Starting task...");
        countDownLatch.countDown();
        System.out.println("Task completed.");
    }

public static void main(String[] args) {
        CountDownLatchExample example = new CountDownLatchExample();

new Thread(() -> example.countdown())).start();

try {
            example.countDownLatch.await(5, TimeUnit.SECONDS));
            System.out.println("All tasks completed.");
        } catch (InterruptedException | TimeoutException e) {
            e.printStackTrace();
            System.out.println("Timeout or interrupted, all tasks stopped.");
        }
    }
}
```
2. CyclicBarrier

- 作用：CyclicBarrier是一个线程同步工具，它在一组等待的线程中创建一个屏障。当一个线程到达屏障时，会向屏障提交一个信号（Signal），然后所有等待的线程都将被唤醒并执行下一个操作。

- 使用示例：
```java
import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierExample {
    private final CyclicBarrier barrier = new CyclicBarrier(2);

public void taskA() throws InterruptedException {
        System.out.println("Task A started.");
        barrier.await(); // Wait until the barrier is crossed by another thread.
        System.out.println("Task A completed.");
    }

public void taskB() throws InterruptedException {
        System.out.println("Task B started.");
        barrier.await(); // Wait until the barrier is crossed by another thread.
        System.out.println("Task B completed.");
    }

public static void main(String[] args) {
        CyclicBarrierExample example = new CyclicBarrierExample();

new Thread(() -> example.taskA())).start();
        new Thread(() -> example.taskB())).start();
    }
}
```
总结，CountDownLatch和CyclicBarrier都是Java并发编程中常用的同步工具。根据实际需求选择合适的工具进行使用。