令仔学多线程系列(一)----同步工具类CountDownLatch

  1. 云栖社区>
  2. 博客>
  3. 正文

令仔学多线程系列(一)----同步工具类CountDownLatch

令仔很忙 2017-02-28 19:33:03 浏览337
展开阅读全文
简单介绍

    
    简单的介绍下CountDownLatch,是在jdk1.5被引入的,是在java.util.concurrent包下,它允许一个或者多个线程一直等待,直到其他线程的操作执行完后再执行。
    
    CountDownLatch是通过一个计数器来实现的,计数器的初始值为线程的数量,下面代码中的count就是初始时设置的线程数量。也就是闭锁需要等待的线程数量。这个值只能被设置一次,而且CountDownLatch没有提供任何机制去重新设置这个计数值。

public CountDownLatch(int count) {...}

    CountDownLatch在主线程启动了设置的线程之后,需要立即调用CountDownLatch.await(),这样主线程的操作就会在这个地方阻塞,知道设置的线程完成各自的任务。

public void await() throws InterruptedException {
        sync.acquireSharedInterruptibly(1);
    }

    有一点需要注意的就是,如果你给某一个东西上了锁,那么你怎么着也得有开锁的时候吧,CountDownLatch也可以当成一把锁来看,所以再每执行完一个线程之后,你都要去开一下锁,就是调用CountDownLatch.countDown()方法。

public void countDown() {
        sync.releaseShared(1);
    }

    目的就是为了你上了10把锁,每执行完一个任务就去解开一把锁,要不然就会一直锁着,线程就会一直阻塞在这个地方。countDown()方法就是开锁的,每调用一次这个方法,count值就会减一,直到为0,主线程就能通过await(),回复执行自己的任务。
    

举个应时的场景

    
    假如我是一个供货的中间代理商,我从供货商那里拿到货然后销售给平台。所有供应商的货物的报价在我这经过处理,每种物品选择一个最低的报价显示在平台上,薄利多销嘛。
这里写图片描述
    如果平台来了一个search请求,我总不能一个供货商一个供货商的去查询吧,查询供应商的数据库还需要时间的,而平台要求的search返回时间肯定不希望太长。而且我最终还有把查到的价格做处理,这些都是时间,时间就是Money。
    
    怎么办?在这里我可以应用CountDownLatch。
    上图中有五个供货商,就设置count数量为5,然后异步发送search请求消息,await一段时间(<平台要求的一次search返回时间),然后把所有的价格统计再进行后期处理。

final CountDownLatch countDownLatch = new CountDownLatch(5);
        for (int i=0;i<5;i++){
            new Thread(new Runnable() {
                @Override
                public void run() {
                    //调用不同的供应商
                    countDownLatch.countDown();   //每new 一个Thread记得要减一。
                }
            }).start();
        }
        try {
            countDownLatch.await(10000, TimeUnit.MILLISECONDS);   //等待10秒(<小于平台要求的返回时间)
            //后续处理
        }catch (InterruptedException e){
            e.printStackTrace();
        }

    先简单的介绍到这里,后期会对CountDownLatch再做深入的研究。

网友评论

登录后评论
0/500
评论
令仔很忙
+ 关注