zoukankan      html  css  js  c++  java
  • CountdownLatch

    import java.util.concurrent.CountDownLatch;
    import java.util.concurrent.CyclicBarrier;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    public class CountdownLatchTest {
    
        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();
    
        }
    }
  • 相关阅读:
    AI 数值计算
    AI 主成分分析(PCA)
    AI 线性代数
    AI 奇异值分解(SVD)
    AI 协同过滤
    AI 卷积神经网络
    AI 随机梯度下降(SGD)
    Ecshop里添加多个h1标题
    Ecshop之ajax修改表里的状态(函数化处理)
    url地址形式的传参格式拼接
  • 原文地址:https://www.cnblogs.com/alamps/p/8196454.html
Copyright © 2011-2022 走看看