前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >java中CountDownLatch线程同步的入门使用

java中CountDownLatch线程同步的入门使用

作者头像
用户5166556
发布2019-04-16 14:33:18
4530
发布2019-04-16 14:33:18
举报

一个同步辅助类,在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待。

下面使用了两个倒计数锁存器:即一个等待另一个的完成

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;


public class CountDownLatchTest {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
        ExecutorService ThreadPool = Executors.newCachedThreadPool();
        final CountDownLatch cdOrder = new CountDownLatch(1);
        final CountDownLatch cdAnswer = new CountDownLatch(3);
        for(int i=0;i<3;i++){
        	 Runnable runnable = new Runnable() {
     			
     			@Override
     			public void run() {
     				
     				try {
     					System.out.println("线程 " + Thread.currentThread().getName() + " 正在等待接受命令");
						cdOrder.await();
						System.out.println("线程 " + Thread.currentThread().getName() + " 已接受命令");
						Thread.sleep((long)Math.random()*10000);
						System.out.println("线程 " + Thread.currentThread().getName() + " 回应命令,处理结果");
						cdAnswer.countDown();
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
     			}
     		};
     		ThreadPool.execute(runnable);
        }
        try {
			Thread.sleep((long)Math.random()*10000);
			System.out.println("线程 " + Thread.currentThread().getName() + " 正在等待发布命令");
			cdOrder.countDown();
			cdAnswer.await();
			System.out.println("线程 " + Thread.currentThread().getName() + " 已发布命令,正在等待结果");
			
			System.out.println("所有命令都处理完");
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
       ThreadPool.shutdown();
	}

}
本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2014年11月04日,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档