浅谈Java的并发工具类：如CountDownLatch等

原创小咪咪 2024-12-01 16:51 99阅读 0赞

Java的并发工具类是Java 5引入的一个重要特性，用于处理线程之间的协调和通信问题。其中，CountDownLatch就是一个典型的并发工具类。

1. CountDownLatch介绍：
CountDownLatch是一个可重置计数器，它最初的设计目的是用来控制一个或多个线程等待其他线程完成特定操作。

2. 使用方式：
- 初始化：创建CountDownLatch实例并设置其初始值（默认为1）。
- 等待：当需要等待某个事件发生（如另一个线程执行完一个任务）时，调用await()方法阻塞当前线程，直到 CountDownLatch 的值减小到0。

3. 示例：
```java
import java.util.concurrent.CountDownLatch;

public class CountDownLatchExample {
    private CountDownLatch countDownLatch;

public CountDownLatchExample(int initialCount) {
        this.countDownLatch = new CountDownLatch(initialCount);
    }

// 线程1，执行完任务后调用countDown方法
    public void thread1() throws InterruptedException {
        System.out.println("Thread 1 Starting...");

// 执行任务，完成后调用 countDown 方法减小计数
        executeTask();

// 阻塞直到 CountDownLatch 的值变为0
        countDownLatch.await();
        System.out.println("Thread 1 Ending...");
    }

// 线程2，执行完任务后调用countDown方法
    public void thread2() throws InterruptedException {
        System.out.println("Thread 2 Starting...");

// 执行任务，完成后调用 countDown 方法减小计数
        executeTask();

// 阻塞直到 CountDownLatch 的值变为0
        countDownLatch.await();
        System.out.println("Thread 2 Ending...");
    }

private void executeTask() throws InterruptedException {
        System.out.println("Thread 1 or Thread 2 Executing Task...");

// 线程阻塞，模拟任务执行时间
        Thread.sleep(5000); // 假设任务耗时5秒

System.out.println("Task Execution Complete...");
    }

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

// 创建线程并启动它们
        Thread thread1 = new Thread(example::thread1));
        Thread thread2 = new Thread(example::thread2));

thread1.start();
        thread2.start();

// 等待所有线程执行完毕
        try {
            thread1.join();
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

System.out.println("All threads completed execution.");
    }
}
```
在这个示例中，我们创建了两个并发任务（thread1和thread2），通过CountDownLatch来协调它们的执行。当所有任务完成后，主线程会打印出相应的结束信息。