CountDownLatch

末蓝、 2024-04-19 14:57 1阅读 0赞

在Java并发编程实战学习到这个，感觉很强大  
先了解一下**闭锁**

## 闭锁 ##

闭锁是一种同步工具类，可以延迟线程的进度知道其到达终止状态。  
举一个例子：宿舍四人ABCD约好一起吃饭，当A收拾完后，发现BCD还没有收拾完，需要等待BCD收拾，知道BCD三人都收拾完后，四人一起出发吃饭。好比宿舍门，这个门是关闭的，没有一人通过，只有当ABCD收拾完，门打开，一起出发。（这个为例子，更好的理解）。  
当闭锁到达结束后，将不在改变状态，因此永远保持打开。

## CountDownLatch ##

CountDownLatch是一个灵活的闭锁实现。闭锁状态包括一个计时器，该计时器被初始化为一个正数，表示需要等待的事件数量。countDown方法为递减计数器，表示有一个事件发生了，await方法为等待计数器达到0，相当于阻塞，一直到计数器为0。如果不好理解，看下列更详细解释  
CountDownLatch(int a) 实例化一个计时器 自己定义个数（相当于计数，四人，ABCD）  
countDown() 该方法让计数减一（四人吃饭A收拾完后，4-1）  
await() 等待，当计数器减到0，所有线程并行执行（全部收拾完，出发，ABC收拾完，等待D）

书中代码实现如下

public class TestHarness {
        public long timeTasks(int nThreads, final Runnable task) throws InterruptedException{
            final CountDownLatch startGate = new CountDownLatch(1);
            final CountDownLatch endGate = new CountDownLatch(nThreads);
    
            for (int i = 0;i<nThreads;i++){
                Thread t = new Thread(){
                    public void run() {
                        try {
                            startGate.await();
                            try {
                                task.run();
                            } finally {
                                endGate.countDown();
                            }
                        } catch (InterruptedException i) {
    
                        }
                    }
                };
                t.start();
            }
            // 计时
            long start = System.nanoTime();
            startGate.countDown();
            endGate.await();
            long end = System.nanoTime();
            return end-start;
        }
    }