Java并发编程:CountDownLatch应用实例
CountDownLatch是Java中一种用于协调多个线程的工具。当一个线程等待其他线程完成某个操作,就可以使用CountDownLatch。
以下是一个简单的CountDownLatch应用实例:
import java.util.concurrent.CountDownLatch;
public class CountDownLatchExample {
private CountDownLatch signal = new CountDownLatch(1);
public void workerThread() {
try {
// 线程需要等待信号量下降到0
signal.await();
// 如果信号量已经降为0,那么线程就可以执行自己的任务了
System.out.println("Worker thread is running...");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
CountDownLatchExample example = new CountDownLatchExample();
// 创建两个工作线程
Thread workerThread1 = new Thread(example::workerThread);
Thread workerThread2 = new Thread(example::workerThread);
// 启动工作线程
workerThread1.start();
workerThread2.start();
// 当主线程等待所有工作线程完成任务时,调用countDown方法
example.signal.countDown();
System.out.println("Main thread completed the task...");
}
}
在这个例子中,我们创建了一个CountDownLatch,然后有两个工作线程。工作线程需要等待信号量降至0才能执行自己的任务。主线程则在所有工作线程完成任务后调用countDown方法来释放信号量。
还没有评论,来说两句吧...