【J.U.C】JAVA并发辅助工具类-CountDownLatch、CyclicBarrier、Semaphore之简单介绍及和Golang的WaitGroup比较

扫码关注公众号:Java 技术驿站

发送:vip
将链接复制到本浏览器,永久解锁本站全部文章

【公众号:Java 技术驿站】 【加作者微信交流技术,拉技术群】

文章首发于:clawhub.club


CyclicBarrier同步屏障

CyclicBarrier默认的构造方法CyclicBarrier(int parties),其参数表示屏障拦截的线程数量,
每个线程调用await方法告诉CyclicBarrier我已经到达屏障,然后当前线程被阻塞,
直到被拦截的线程全部都到达了屏障,然后前面被阻塞的线程才能开始执行,否则会被一直阻塞。
就像正式场合围着桌子吃饭,要等所有人都到到齐之后,才可以开餐。先来的人要等待。

查看栅栏类可以看到其主要是由ReentrantLock和Condition结合计数器实现。

Semaphore

信号量用于控制线程的并发数量,线程只有拿到许可证的时候才能执行。其源码中通过Sync同步器实现了AQS的共享模式。
因为刚刚分析完ReentrantReadWriteLock中的读锁,实现方式差不多,所以在这就不分析源码了。
比喻:吃饭的时候,有一碗汤,只有两个勺子,也就是说同时只能由两个人拿到勺子成汤,其他人没拿到勺子,只能吃别的东西。

CountDownLatch

为什么最后说这个类呢,因为它的功能和Golang中的WaitGroup很相似:都属于倒计时类型。
在一些应用场景中,主线程需要等待某些条件达到要求后才能做后面的事情,
同时当线程都完成后也会触发事件,以便进行后面的操作。
CountDownLatch最重要的方法是countDown()和await(),前者主要是倒数一次,后者是等待倒数到0,如果没有到达0,就阻塞等待。
CountDownLatch源码中实现了AQS的共享锁,比较简单。

WaitGroup

Golang中sync包中的WaitGroup实现的功能与CountDownLatch类似,主线程需要等待其他协程处理完所有任务之后才能继续向下执行。

    var wg sync.WaitGroup
        wg.Add(3)
        wg.Done()
        wg.Wait()

这几个方法与JAVA中的很相似:
wg.Add(3)对应CountDownLatch的构造方法
wg.Done()对应CountDownLatch的countDown()
wg.Wait()对应CountDownLatch的await()


来源:https://www.jianshu.com/p/347ea7f881f8

赞(0) 打赏
版权归原创作者所有,任何形式的转载请联系博主:daming_90:Java 技术驿站 » 【J.U.C】JAVA并发辅助工具类-CountDownLatch、CyclicBarrier、Semaphore之简单介绍及和Golang的WaitGroup比较

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏