转载

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

CyclicBarrier默认的构造方法CyclicBarrier(int parties)，其参数表示屏障拦截的线程数量，

每个线程调用await方法告诉CyclicBarrier我已经到达屏障，然后当前线程被阻塞，

直到被拦截的线程全部都到达了屏障，然后前面被阻塞的线程才能开始执行，否则会被一直阻塞。

就像正式场合围着桌子吃饭，要等所有人都到到齐之后，才可以开餐。先来的人要等待。

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

信号量用于控制线程的并发数量，线程只有拿到许可证的时候才能执行。其源码中通过Sync同步器实现了AQS的共享模式。

因为刚刚分析完ReentrantReadWriteLock中的读锁，实现方式差不多，所以在这就不分析源码了。

比喻：吃饭的时候，有一碗汤，只有两个勺子，也就是说同时只能由两个人拿到勺子成汤，其他人没拿到勺子，只能吃别的东西。

为什么最后说这个类呢，因为它的功能和Golang中的WaitGroup很相似：都属于倒计时类型。

在一些应用场景中，主线程需要等待某些条件达到要求后才能做后面的事情，

同时当线程都完成后也会触发事件，以便进行后面的操作。

CountDownLatch最重要的方法是countDown()和await()，前者主要是倒数一次，后者是等待倒数到0，如果没有到达0，就阻塞等待。

CountDownLatch源码中实现了AQS的共享锁，比较简单。

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://studygolang.com/articles/22003

正文到此结束

所属分类：编程技术 Java

本文标签： 构造方法 https IO 源码 http java 同步锁 Semaphore 参数 CyclicBarrier map 并发线程 CountDownLatch
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。