java高并发之CountDownLatch，CyclicBarrier和join

晚上打车回家，在车上看到一篇文章《22岁大学生获谷歌天价Offer，年薪千万！》，讲的是印度一个22岁大学生多次参加ACM大赛，开源多个项目，以非常牛逼的履历通过了谷歌的AI测试，斩获谷歌仅有的50个顶尖offer之一。于是感慨：同样是大学生，为何这哥们就这么一枝独秀呢？难道印度也有陈独秀？为啥自己都12年义务教育+4年大学教育+3年烟酒僧教育了，连人家个零头都挣不了啊？真恨不得在地上挖个洞钻进去。不行，今晚必须输出篇博客安慰下被打击的心！想到这里顿时酒也醒了（老大走了，今晚几个同事送他，喝了点酒），心也不再那么伤感了，决定把今天get的一些知识点做个梳理，知识是一点点积累起来的，比你牛逼的人比你还努力，你还有什么资格不努力？

早上看了下CountDownLatch和CyclicBarrier的用法和区别，讲到CountDownLatch又想到了Thread.join()方法，就来讲讲这3兄弟的功能，特点&&用法，讲的不对的地方欢迎指正。

一、CountDownLatch：

功能：同步辅助类，也可以理解为倒计时锁，用于同步线程状态，允许一个或多个线程，等待其他一组线程完成操作，再继续往下执行。

特点：不可复用！

重要方法：countDown()方法：计数器-1，每次线程执行完后调用；await（）方法：等待方法，在需要阻塞的地方调用，当所有线程都执行完后，自动往下执行

用法：构造的时候指定一个计数器的值，每个线程执行完后就减1，直到为0再往下走。如下：



输出结果：



可以看到：2个子线程分别睡眠了3s和5s，而主线的打印的“所有现场执行完毕”却是在所有子线程执行完成后才输出的，原因就是阻塞在了latch.await()方法，这个方法会等到所有线程都执行完才往下执行，阻塞的原理后面有空再研究分析

二、CyclicBarrier（循环栅栏）：

功能：同步辅助类，功能和CountDownLatch类似，用于同步线程状态，允许一组线程相互之间等待，达到一个共同点，再继续执行。

特点：可复用！当组内所有线程都到达某个执行点后，count参数会被重置，于是就可重用了。

重要方法：await（）方法：当某个线程到达某个点（比如执行完某个任务）后调用该方法，就会等待其他线程，直到所有线程都到达这个点，再自动往下执行。还有个重载方法await（long timeOut,TimeUnit unit），用于当某个线程执行超过指定时间后还未到达某个点时，就会抛出异常，不再等待这个线程，并往下执行。

用法：构造的时候指定一个线程数量的值和到达某个点后执行的动作，如下：



执行结果如下：



可以看到：当前线程先于2个子线程打印执行结果，原因就是CyclicBarrier针对的是一组线程之间的等待，await方法会等待该组内所有线程都执行完毕再往下执行，Runnable接口里定义的动作是在所有线程执行完毕后，随机选择一个线程来执行

三、join（）方法：

join方法也是管理线程状态同步的一个方法，和CountDownLatch和CyclicBarrier均由自身调用不同的是，join的调用者为当前线程，后面的线程必须等调用join的线程执行完后才能执行。参考例子如下：



执行结果：



结果分析：新创建了2个线程，每个线程的执行功能和时间是一样的，由于调用了join，主线程确实是在调用join的2个线程执行后才开始执行的

3者区别：

1、CountDownLatch不可复用，当计数器减为0后，只能重新构造新的计数器，CyclicBarrier可以复用，原因上面已说。

2、CyclicBarrier针对的是一组线程之间的等待，是组内等待关系，CountDownLatch针对的是一个线程等待别的一组线程的关系，是组间等待关系。

3、join方法和CountDownLatch方法功能类似，但是join方法不如CountdownLatch控制灵活，可以参考：https://blog.csdn.net/zhutulang/article/details/48504487。

本来还想讲讲volatile关键字的原理和特性，以及activeMQ中quene,topic和virtualTop之间的区别和用法的，以及mysql索引结构的实现原理的，时间不够了，明早还要去申请廉租房得早起，下次再讲吧。