十年网站开发经验 + 多家企业客户 + 靠谱的建站团队
量身定制 + 运营维护+专业推广+无忧售后,网站问题一站解决
前言
目前创新互联建站已为上千的企业提供了网站建设、域名、虚拟主机、网站托管、服务器托管、企业网站设计、贵港网站维护等服务,公司将坚持客户导向、应用为本的策略,正道将秉承"和谐、参与、激情"的文化,与客户和合作伙伴齐心协力一起成长,共同发展。CountDownLatch 允许一个或多个线程等待其他线程完成操作。
应用场景
假如有一个列表的大量数据等待处理,最后全部处理完毕后返回处理结果。普通做法就是从头遍历,一个个顺序执行,这样单线程处理效率不高,我们希望使用多线程的方式处理,同时在主线程等待所有子线程处理完成。
CountDownLatch的构造函数接收一个int类型的参数作为计数器,如果你想等待N个点完成,这里就传入N。
当我们调用一次CountDownLatch的countDown方法时,N就会减1,CountDownLatch的await会阻塞当前线程,直到N变成零。由于countDown方法可以用在任何地方,所以这里说的N个点,可以是N个线程,也可以是1个线程里的N个执行步骤。用在多个线程时,你只需要把这个CountDownLatch的引用传递到线程里。
示例代码
public static void main(String args[]){ //初始化计数 AtomicInteger count = new AtomicInteger(0); //创建10个线程 ExecutorService executorService = Executors.newFixedThreadPool(10); //设置CountDownLatch为10 CountDownLatch countDownLatch = new CountDownLatch(10); for(int i=0;i<10;i++){ executorService.execute(() -> { //每个线程累加10000次 for(int j=0;j<10000;j++){ count.addAndGet(1); } //线程最后执行countDown countDownLatch.countDown(); }); } try{ //调用await方法等待 countDownLatch.await(); }catch(Exception e){ e.printStackTrace(); } System.out.println(count.toString()); }