Java提高——JUC线程CountDownLatch闭锁

Love The Way You Lie 2022-05-20 02:16 205阅读 0赞

#### CountDownLatch闭锁 ####

*  java5.0后在java.util.concurrent包中提供了许多种并发容器类来改进同步容器的性能。
 *  CountdownLatch一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。
 *  闭锁可以延迟线程的进度知道其到达终止状态，闭锁可以用来确保某些活动直到其他其他活动都完成才继续执行：  
    1）确保某个计算在其需要的所有资源都被初始化之后才继续执行；  
    2）确保某个服务在其依赖的所有其他服务都已经启动之后才启动；  
    3）等待直到某个操作所有参与者都准备就绪再继续执行。

实例：

public class TestCountDownLatch {
        public static void main(String[] args) {
            CountDownLatch countDownLatch = new CountDownLatch(5);
            Latch latch = new Latch(countDownLatch);
            Long start = System.currentTimeMillis();
            for (int i = 0; i < 10; i++) {
                new Thread(latch).start();
            }
            Long end = System.currentTimeMillis();
            System.out.println("消耗的时间 "+(end-start));
        }
    }
    
    class Latch implements Runnable{
        private CountDownLatch countDownLatch;
    
        public Latch(CountDownLatch countDownLatch) {
            this.countDownLatch = countDownLatch;
        }
    
        @Override
        public void run() {
            for (int i = 0; i < 50000; i++) {
                if (i%2==0){
                    System.out.println(i);
                }
            }
        }
    }

这样无法求出消耗的时间，因为main线程和其余的10个线程是同时执行的，没法求出时间

我们希望当其余的10个线程执行完了之后再执行main线程，这样求出消耗的时间。

/** * @author chenpeng * @date 2018/7/10 22:24 * * CountDownLatch：闭锁 在完成某些运算时只有其他线程的运算全部完成，当前运算才会继续执行 */ public class TestCountDownLatch {
        public static void main(String[] args) {
            //每个线程操作都会使括号中的数字递减一
            CountDownLatch countDownLatch = new CountDownLatch(10);
            Latch latch = new Latch(countDownLatch);
            Long start = System.currentTimeMillis();
            for (int i = 0; i < 10; i++) {
                new Thread(latch).start();
            }
    
            //让线程等待
            try {
                countDownLatch.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
    
            Long end = System.currentTimeMillis();
            System.out.println("消耗的时间 "+(end-start));
        }
    }
    
    class Latch implements Runnable{
        private CountDownLatch countDownLatch;
    
        public Latch(CountDownLatch countDownLatch) {
            this.countDownLatch = countDownLatch;
        }
    
        @Override
        public void run() {
            synchronized (this){
                try {
                    for (int i = 0; i < 50000; i++) {
                        if (i%2==0){
                            System.out.println(i);
                        }
                    }
                } finally {
                    //闭锁减一，直到为0，一定要执行
                    countDownLatch.countDown();
                }
            }
        }
    }

![70][]

[70]: /images/20220520/bd6d2f222d8a43748f33434537448ac2.png