Java并发编程：基于CountDownLatch的异步任务案例解析

原创红太狼 2024-10-22 03:09 40阅读 0赞

在Java并发编程中，CountDownLatch是一种同步工具，它允许一个或多个线程等待其他线程完成一些工作。当工作完成后，调用release方法来通知等待的线程。

下面是一个基于CountDownLatch的异步任务案例解析：

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

class WorkerThread extends Thread {
    private CountDownLatch latch; // 使用CountDownLatch

public WorkerThread(CountDownLatch latch) {
        this.latch = latch;
    }

@Override
    public void run() {
        try {
            System.out.println("Worker thread started...");
            // 假设这里是一个耗时操作，比如发送邮件或处理大数据等。
            TimeUnit.SECONDS.sleep(5); // 耗时操作

// 当操作完成后，调用release方法通知CountDownLatch
            System.out.println("Worker thread completed the task, releasing latch...");
            latch.countDown();
        } catch (Exception e) {
            System.err.println("Error occurred in worker thread: " + e.getMessage());
        }
    }
}

public class CountDownLatchExample {
    public static void main(String[] args) {
        // 创建CountDownLatch，初始值为1（表示有一个任务等待完成）
        CountDownLatch latch = new CountDownLatch(1);

// 创建WorkerThread线程实例，并传入CountDownLatch
        WorkerThread workerThread = new WorkerThread(latch);

// 启动WorkerThread
        workerThread.start();

// 在主线程中，通过调用countDown方法来减少CountDownLatch的计数（表示一个任务已经完成）
        System.out.println("Main thread decreasing latch count...");
        latch.countDown();

// 等待WorkerThread线程结束
        workerThread.join();

System.out.println("Example completed.");
    }
}
```

以上代码创建了一个异步任务，通过CountDownLatch来控制多个WorkerThread的执行顺序。当所有工作完成后，主线程会调用countDown方法来通知CountDownLatch。