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

clawhub · · 920 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

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()


有疑问加站长微信联系(非本文作者)

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

920 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传