并发包中关于CountDownLatch类的使用

简介:

一个非常有用的类,CountDownLatch, 可以用来在一个线程中等待多个线程完成任务的类;
通常的使用场景是,某个主线程接到一个任务,起了n个子线程去完成,但是主线程需要等待这n个子线程都完成任务了以后才开始执行某个操作;

测试代码如下:

package test;

import java.util.concurrent.CountDownLatch;

public class TestThread {

 /**
  *
  * @author Administrator/2012-3-1/上午09:19:02
  */
 public static void main(String[] args) {

  TestThread t=new TestThread();
  t.demoCountDown();

 }
 
 
 public void demoCountDown()  
 {  
     int count = 10;  
  
     final CountDownLatch l = new CountDownLatch(count);  
     for(int i = 0; i < count; ++i)  
     {  
         final int index = i;  
         new Thread(new Runnable() {  
  
             @Override 
             public void run() {  
  
                 try {  
                     Thread.currentThread().sleep(20 * 1000);  
                 } catch (InterruptedException e) {  
  
                     e.printStackTrace();  
                 }  
  
                 System.out.println("thread " + index + " has finished...");  
  
                 l.countDown();  
  
             }  
         }).start();  
     }  
  
     try {  
         l.await();  
     } catch (InterruptedException e) {  
  
         e.printStackTrace();  
     }  
  
     System.out.println("now all threads have finished");  
  
 } 


}

 

 

运行结果:

 

 

thread 1 has finished...
thread 3 has finished...
thread 0 has finished...
thread 7 has finished...
thread 4 has finished...
thread 9 has finished...
thread 8 has finished...
thread 2 has finished...
thread 6 has finished...
thread 5 has finished...
now all threads have finished

 

前面10个线程的执行完成顺序会变化,但是最后一句始终会等待前面10个线程都完成之后才会执行.

 


 

目录
相关文章
|
2月前
|
Java C++
【多线程】JUC的常见类,Callable接口,ReentranLock,Semaphore,CountDownLatch
【多线程】JUC的常见类,Callable接口,ReentranLock,Semaphore,CountDownLatch
34 0
|
4月前
|
消息中间件 RocketMQ
CountDownLatch原理
文章讲述了CountDownLatch的工作原理及其用途: 1. CountDownLatch是一个简单的同步工具,用于等待一组操作完成。 2. 它通过AQS框架实现,利用共享锁模式控制线程的等待与唤醒。 3. 适用于多线程环境下,一个线程需要等待多个其他线程完成各自的任务后再继续执行的场景。
|
6月前
|
Java
Runnable+CountDownLatch多线程的等待和通知
Runnable+CountDownLatch多线程的等待和通知
|
6月前
|
存储 并行计算 Java
Java8中JUC包同步工具类深度解析(Semaphore,CountDownLatch,CyclicBarrier,Phaser)
Java8中JUC包同步工具类深度解析(Semaphore,CountDownLatch,CyclicBarrier,Phaser)
55 2
|
7月前
|
Java
JUC 常用 4 大并发工具类 CountDownLatch、CyclicBarrier、Semaphore、ExChanger
JUC 常用 4 大并发工具类 CountDownLatch、CyclicBarrier、Semaphore、ExChanger
Java JUC并发包之CyclicBarrier循环栅栏
Java JUC并发包之CyclicBarrier循环栅栏
Java JUC并发包之CyclicBarrier循环栅栏
|
安全 Java 测试技术
CountDownLatch原理剖析
CountDownLatch原理剖析
110 0
Java——多线程高并发系列之JUC三大辅助类(CountDownLatch、CyclicBarrier、Semaphore)
Java——多线程高并发系列之JUC三大辅助类(CountDownLatch、CyclicBarrier、Semaphore)
Java——多线程高并发系列之JUC三大辅助类(CountDownLatch、CyclicBarrier、Semaphore)