博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
java中的CountDownLatch
阅读量:6496 次
发布时间:2019-06-24

本文共 2196 字,大约阅读时间需要 7 分钟。

  闭锁是一种同步工具类,可以延迟线程的进度直到其达到终止状态。闭锁的作用相当于一扇门:在闭锁到达结束状态值钱,这扇门一直是关闭的,没有任何线程可以通过,当到大结束状态时,这扇门会打开并允许所有的线程通过。当闭锁到达结束状态后,将不再改变状态,因此这扇门将永远保持打开状态。

  闭锁可以用来确保某些活动直到其他活动都完成后才继续执行,例如:

  1.确保某个计算在其需要的所有资源都被初始化之后才继续执行。

  2.确保某个服务在期以来的其他所有服务都启动之后才启动。

  3.等待直到某个操作的所有参与者都就绪再继续执行。

 

  CountDownLatch是一种灵活的闭锁实现,可以在上述各种情况中使用,它可以在上述各种情况中使用。countDown方法递减计数器,表示已经有一个时间发生,而await方法等待计数器达到0,这表示所有的事情已经发生。如果计数器非零,那么await将一直阻塞到计数器为0,或者等待中的线程中断,或者等待超时

 

  程序,在计时测试中使用CountDownLatch来启动和停止线程

  

package concurrent.learn;import java.util.concurrent.CountDownLatch;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(new Runnable() {                @Override                public void run() {                    try {                        startGate.await();                        try {                            task.run();                        } finally {                            endGate.countDown();                        }                    } catch (InterruptedException e) {                        // TODO Auto-generated catch block                        e.printStackTrace();                    }                }            });            t.start();        }        long start = System.nanoTime();        startGate.countDown();        endGate.await();        long end = System.nanoTime();                return end -start;            }        public static void main(String[] args) throws InterruptedException {        Runnable r = new Runnable() {                        @Override            public void run() {                System.out.println(555);                            }        };        TestHarness t = new TestHarness();        long time = t.timeTasks(5, r);                System.out.println(time);            }}

startGate的计数器初始值为1,而结束门的计数器初始值为工作线程的数量。每个工作线程首先要在startGate上等待,从而确保所有线程都就绪后才开始执行。而每个线程要做的最后一件事情就是调用endGate的countDown方法减1,这能使得主线程高效的等待直到所有的工作线程都执行完成,因而可以统计所消耗的时间。

转载于:https://www.cnblogs.com/hupengcool/p/3233647.html

你可能感兴趣的文章
accept()
查看>>
USB 2.0 Hub IP Core
查看>>
USB 2.0 OTG IP Core
查看>>
解读浮动闭合最佳方案:clearfix
查看>>
Charles使用
查看>>
Python GUI编程(Tkinter) windows界面开发
查看>>
P(Y|X) 和 P(X,Y)
查看>>
dynamic关键字的使用
查看>>
iOS 音乐播放器之锁屏效果+歌词解析
查看>>
【转】Google 的眼光
查看>>
android O 蓝牙设备默认名称更改
查看>>
阳台的青椒苗
查看>>
swapper进程【转】
查看>>
跨链技术与通证经济
查看>>
爬虫学习之-xpath
查看>>
js jQuery 右键菜单 清屏
查看>>
深入理解let和var的区别(暂时性死区)!!!
查看>>
dotConnect for Oracle
查看>>
Eclipse下C/C++开发环境搭建
查看>>
Eclipse中设置在创建新类时自动生成注释
查看>>