原创:转载需注明原创地址 https://www.cnblogs.com/fanerwei222/p/11867656.html
Java线程--CountDownLatch使用, 代码里头有详细注释:
public static void main(String[] args) throws InterruptedException {
/**
* 基于计数器的线程等待-完毕执行控制器
* 线程A调用await()方法后, 只有计数为0, 线程A才能继续执行, 否则将一直挂起
*/
CountDownLatch countDownLatch = new CountDownLatch(2);
System.out.println("主线程开始执行");
ExecutorService service1 = Executors.newSingleThreadExecutor();
service1.execute(new Runnable() {
@Override
public void run() {
try {
Thread.sleep(3000);
System.out.println("子线程:"+Thread.currentThread().getName()+"执行");
} catch (InterruptedException e) {
e.printStackTrace();
}
/**
* 计数器的值减1
*/
countDownLatch.countDown();
}
});
service1.shutdown();
ExecutorService service2 = Executors.newSingleThreadExecutor();
service2.execute(new Runnable() {
@Override
public void run() {
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
/\*\*
\* 计数器的值减1
\*/
System.out.println("子线程:"+Thread.currentThread().getName()+"执行");
countDownLatch.countDown();
}
});
service2.shutdown();
System.out.println("等待两个线程执行完毕…… ……");
try {
/\*\*
\* 主线程里面调用的await()方法, 那么主线程在这里会被挂起,
\* 等到countDownLatch的计数为0的时候再继续回来执行
\*/
countDownLatch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("两个子线程都执行完毕,继续执行主线程");
}
打印如下:
主线程开始执行
等待两个线程执行完毕…… ……
子线程:pool-1-thread-1执行
子线程:pool-2-thread-1执行
两个子线程都执行完毕,继续执行主线程
手机扫一扫
移动阅读更方便
你可能感兴趣的文章