zoukankan      html  css  js  c++  java
  • java 多线程 day16 CountDownLatch 倒计时计数器


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

    public class Thread1601_CountDownLatch {

    public static void main(String[] args) {
    ExecutorService service = 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(){
    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 (Exception e) {
    e.printStackTrace();
    }
    }
    };
    service.execute(runnable);
    }
    try {
    Thread.sleep((long)(Math.random()*10000));

    System.out.println("线程" + Thread.currentThread().getName() +
    "即将发布命令");
    cdOrder.countDown();
    System.out.println("线程" + Thread.currentThread().getName() +
    "已发送命令,正在等待结果");
    cdAnswer.await();
    System.out.println("线程" + Thread.currentThread().getName() +
    "已收到所有响应结果");
    } catch (Exception e) {
    e.printStackTrace();
    }
    service.shutdown();

    }
    }
  • 相关阅读:
    解决maven构建webapp index.jsp报错问题
    Maven入门介绍
    Linux常用命令的解释
    linux怎么查看一个文件夹的大小
    EPEL源-是什么全称
    nginx+php-fpm配置后页面显示空白的解决方法(yum形式的安装)
    配置新服务器 的一些 依赖库 php mysql nginx
    服务器 CentOS上yum安装Nginx服务
    Java File创建新目录和文件
    struts2的文件上传
  • 原文地址:https://www.cnblogs.com/ctaixw/p/7980976.html
Copyright © 2011-2022 走看看