Java并发编程:CountDownLatch应用实例

原创 曾经终败给现在 2024-10-21 09:39 190阅读 0赞

CountDownLatch是Java中一种用于协调多个线程的工具。当一个线程等待其他线程完成某个操作,就可以使用CountDownLatch。

以下是一个简单的CountDownLatch应用实例:

  1. import java.util.concurrent.CountDownLatch;
  2. public class CountDownLatchExample {
  3. private CountDownLatch signal = new CountDownLatch(1);
  4. public void workerThread() {
  5. try {
  6. // 线程需要等待信号量下降到0
  7. signal.await();
  8. // 如果信号量已经降为0,那么线程就可以执行自己的任务了
  9. System.out.println("Worker thread is running...");
  10. } catch (InterruptedException e) {
  11. e.printStackTrace();
  12. }
  13. }
  14. public static void main(String[] args) {
  15. CountDownLatchExample example = new CountDownLatchExample();
  16. // 创建两个工作线程
  17. Thread workerThread1 = new Thread(example::workerThread);
  18. Thread workerThread2 = new Thread(example::workerThread);
  19. // 启动工作线程
  20. workerThread1.start();
  21. workerThread2.start();
  22. // 当主线程等待所有工作线程完成任务时,调用countDown方法
  23. example.signal.countDown();
  24. System.out.println("Main thread completed the task...");
  25. }
  26. }

在这个例子中,我们创建了一个CountDownLatch,然后有两个工作线程。工作线程需要等待信号量降至0才能执行自己的任务。主线程则在所有工作线程完成任务后调用countDown方法来释放信号量。

文章版权声明:注明蒲公英云原创文章,转载或复制请以超链接形式并注明出处。

发表评论

表情:
评论列表 (有 0 条评论,190人围观)

还没有评论,来说两句吧...

相关阅读