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类似,主线程需要等待其他协程处理完所有任务之后才能继续向下执行。

1
2
3
4
var wg sync.WaitGroup
wg.Add(3)
wg.Done()
wg.Wait()

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