Java并发工具库：CountDownLatch和CyclicBarrier示例

原创迷南。 2024-09-16 06:04 83阅读 0赞

在Java中，`CountDownLatch`和`CyclicBarrier`是两个常用的并发工具类，分别用于控制一个或多个线程等待特定事件的发生。

1. CountDownLatch示例：

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

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

public void workerThread(int index) {
        try {
            System.out.println("Worker thread " + index);
            // 模拟耗时操作，实际上可以是网络请求等
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        countDownLatch.countDown();  // 当线程执行完这一行后，countDownLatch的计数会减少一次
        System.out.println("Worker thread " + index + " finished.");
    }

public static void main(String[] args) throws InterruptedException {
        CountDownLatchExample example = new CountDownLatchExample();
        Thread t1 = new Thread(example::workerThread, 1));
        Thread t2 = new Thread(example::workerThread, 2));
        Thread t3 = new Thread(example::workerThread, 3));

t1.start();  // 启动第一个线程
        t2.start();
        t3.start();

// 等待所有线程完成
        countDownLatch.await();  // CountDownLatch的countDown方法会将计数减一，所以在这里等待计数归零

System.out.println("All threads finished.");
    }
}
```

在上述示例中，创建了一个`CountDownLatch`实例，其初始计数值为3（表示有3个任务需要完成）。然后开启三个线程 workerThread，每个线程执行完自己的任务后调用`countDownLatch.countDown()`方法将计数减一。

最后在主线程中等待所有线程完成，当`CountDownLatch`的计数归零时，主线程会继续执行。