CyclicBarrier 用法
从字面上这个类可以理解为环形屏障,它可以协同多个线程,让多个线程在这个屏障前等待。当所有线程都达到这个屏障时,再一起执行后续的动作。如下图:
三个线程各有一个barrier.await,那么任何一个线程执行到barrier.await时就会进入阻塞状态进行等待,知道三个线程都达到了barrier.await才会同时从await返回,就需后续的工作。此外,如果在构造CyclicBarrier时设置了Runnable实现,那么最后一个到barrier.await的线程会执行Runnable的run方法。
结合例子看一下:
public class TCyclicBarrierestDemo {
private static int count = 10;
public static void main(String[] args) {
CyclicBarrier cb = new CyclicBarrier(count, new Runnable() {
@Override
public void run() {
System.out.println("Runnable实现方法运行了");//当所有线程到达“屏障”时执行
}
});
for (int i = 0; i < count; i++) {
new Thread(new WorkerThread(cb)).start();
}
}
}
class WorkerThread implements Runnable{
CyclicBarrier barrier;
public WorkerThread(CyclicBarrier b){
this.barrier = b;
}
@Override
public void run() {
try{
System.out.println("线程到达屏障,开始等待");
barrier.await();//线程在这里等待,直到所有线程都到达“屏障”。
System.out.println("线程"+Thread.currentThread().getName()+" 开始后续工作");
}catch(Exception e){
e.printStackTrace();
}
}
}
运行结果:
线程到达屏障,开始等待
线程到达屏障,开始等待
线程到达屏障,开始等待
线程到达屏障,开始等待
线程到达屏障,开始等待
线程到达屏障,开始等待
线程到达屏障,开始等待
线程到达屏障,开始等待
线程到达屏障,开始等待
线程到达屏障,开始等待
Runnable实现方法运行了
线程Thread-8 开始后续工作
线程Thread-5 开始后续工作
线程Thread-1 开始后续工作
线程Thread-6 开始后续工作
线程Thread-9 开始后续工作
线程Thread-4 开始后续工作
线程Thread-0 开始后续工作
线程Thread-7 开始后续工作
线程Thread-2 开始后续工作
线程Thread-3 开始后续工作
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 11
- 12
- 13
- 14
- 15
- 16
- 17
- 18
- 19
- 20
- 21
- 22
- 23
- 24
- 25
- 26
- 27
- 28
- 29
- 30
- 31
- 32
- 33
- 34
- 35
- 36
- 37
- 38
- 39
- 40
- 41
- 42
- 43
- 44
- 45
- 46
- 47
- 48
- 49
- 50
- 51
- 52
- 53
- 54
- 55
- 56
- 57
<link href="https://csdnimg.cn/release/phoenix/mdeditor/markdown_views-8cccb36679.css" rel="stylesheet">
</div>
<script>
(function(){
function setArticleH(btnReadmore,posi){
var winH = $(window).height();
var articleBox = $("div.article_content");
var artH = articleBox.height();
if(artH > winH*posi){
articleBox.css({
'height':winH*posi+'px',
'overflow':'hidden'
})
btnReadmore.click(function(){
articleBox.removeAttr("style");
$(this).parent().remove();
})
}else{
btnReadmore.parent().remove();
}
}
var btnReadmore = $("#btn-readmore");
if(btnReadmore.length>0){
if(currentUserName){
setArticleH(btnReadmore,3);
}else{
setArticleH(btnReadmore,1.2);
}
}
})()
</script>
</article>