当前位置: 首页 > 工具软件 > Countdown > 使用案例 >

CountDownLatch之countDown()放在子线程的方法里

和嘉澍
2023-12-01

 CountDownLatch典型用法1:某一线程在开始运行前等待n个线程执行完毕。将CountDownLatch的计数器初始化为n new CountDownLatch(n) ,每当一个任务线程执行完毕,就将计数器减1 countdownlatch.countDown(),当计数器的值变为0时,在CountDownLatch上 await() 的线程就会被唤醒。一个典型应用场景就是启动一个服务时,主线程需要等待多个组件加载完毕,之后再继续执行。

/**
 * CountDownLatch:多线程控制工具类,用来控制线程等待,它可以让某一个线程等待知道倒计时结束,再开始执行
 */
public class CountDownLatchDemo {

    //实例化并指定计数个数
    private  static CountDownLatch countDown = new CountDownLatch(3);

    public static Runnable r1 = new Runnable(){
        @Override
        public void run() {
            try{
                Thread.sleep(1000);
                System.out.println("r1 run");
                countDown.countDown();//个数-1
            }catch (Exception e){
                e.printStackTrace();
            }

        }
    };

   public static Runnable r2 = new Runnable() {
        @Override
        public void run() {
            try{
                Thread.sleep(2000);
                System.out.println("r2 run");
                countDown.countDown();
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    };

    public  static Runnable r3 = new Runnable() {
        @Override
        public void run() {
            try{
                Thread.sleep(1000);
                System.out.println("r3 run");
                countDown.countDown();
            }catch (Exception e){
                e.printStackTrace();
            }
        }
    };

    public static void main(String[] args) throws  Exception{
        System.out.println("===begin=====");
        ExecutorService exec = Executors.newFixedThreadPool(3);
        exec.submit(r1);
        exec.submit(r2);
        exec.submit(r3);

        //等待检查,等待三个线程都执行完成后,主线程才能继续执行
        countDown.await();

        System.out.println("====end=====");
        exec.shutdown();
    }
}

输出结果:

===begin=====
r1 run
r3 run
r2 run
====end=====

 

 类似资料: