Java并发编程实战：CountDownLatch和CyclicBarrier使用示例-蒲公英云

Java并发编程实战：CountDownLatch和CyclicBarrier使用示例

原创朱雀 2024-10-24 08:27 145阅读 0赞

在Java的并发编程中，CountDownLatch和CyclicBarrier都是用于协调多个线程活动的重要工具。

CountDownLatch：

CountDownLatch最初是由Sun Microsystems引入Java 1.5的一个类。它是一个线程同步工具，表示一个或多个任务完成后会通知所有等待的任务。

使用示例：

import java.util.concurrent.CountDownLatch;
public class CountdownExample {
    private CountDownLatch countDownLatch;
    public CountdownExample(int count) {
        this.countDownLatch = new CountDownLatch(count);
    }
    public void startTask() throws InterruptedException {
        System.out.println("Task started...");
        countDownLatch.await();
        System.out.println("Task completed.");
    }
    public static void main(String[] args) {
        CountdownExample example = new CountdownExample(3);
        // 创建两个线程来执行任务
        Thread task1Thread = new Thread(() -> example.startTask()));
        Thread task2Thread = new Thread(() -> example.startTask()));
        // 启动这两个线程
        task1Thread.start();
        task2Thread.start();
        // 等待所有任务完成后关闭CountDownLatch
        countDownLatch.countDown();
    }
}

在这个示例中，CountDownLatch用于协调两个任务。当计数器的值减少到零时，所有等待的任务都会被唤醒。

CyclicBarrier：

CyclicBarrier是Java并发API提供的一个同步工具。它的主要作用是在一组共享资源需要同时访问的时候提供一种同步机制。

使用示例：

import java.util.concurrent.CyclicBarrier;
public class CyclicBarrierExample {
    private CyclicBarrier barrier;
    public CyclicBarrierExample(int parties) {
        this.barrier = new CyclicBarrier(parties);
    }
    public void startTask() throws InterruptedException {
        System.out.println("Task started...");
        barrier.await();
        System.out.println("Task completed.");
    }
    public static void main(String[] args) {
        CyclicBarrierExample example = new CyclicBarrierExample(3);
        // 创建两个线程来执行任务
        Thread task1Thread = new Thread(() -> example.startTask()));
        Thread task2Thread = new Thread(() -> example.startTask()));
        // 启动这两个线程
        task1Thread.start();
        task2Thread.start();
        // 等待所有任务完成后关闭CyclicBarrier
        barrier.await(); // 注意：这个操作会阻塞，直到所有的任务完成并调用await方法。
    }
}