Java并發(fā)編程之柵欄(CyclicBarrier)實例介紹
柵欄類似閉鎖,但是它們是有區(qū)別的.
1.閉鎖用來等待事件，而柵欄用于等待其他線程.什么意思呢?就是說閉鎖用來等待的事件就是countDown事件,只有該countDown事件執(zhí)行后所有之前在等待的線程才有可能繼續(xù)執(zhí)行;而柵欄沒有類似countDown事件控制線程的執(zhí)行,只有線程的await方法能控制等待的線程執(zhí)行.
2.CyclicBarrier強調(diào)的是n個線程，大家相互等待，只要有一個沒完成，所有人都得等著。
場景分析:10個人去春游,規(guī)定達到一個地點后才能繼續(xù)前行.代碼如下
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
class CyclicBarrierWorker implements Runnable {
private int id;
private CyclicBarrier barrier;
public CyclicBarrierWorker(int id, final CyclicBarrier barrier) {
this.id = id;
this.barrier = barrier;
}
@Override
public void run() {
// TODO Auto-generated method stub
try {
System.out.println(id + " th people wait");
barrier.await(); // 大家等待最后一個線程到達
} catch (InterruptedException | BrokenBarrierException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
public class TestCyclicBarrier {
public static void main(String[] args) {
int num = 10;
CyclicBarrier barrier = new CyclicBarrier(num, new Runnable() {
@Override
public void run() {
// TODO Auto-generated method stub
System.out.println("go on together!");
}
});
for (int i = 1; i <= num; i++) {
new Thread(new CyclicBarrierWorker(i, barrier)).start();
}
}
}
輸出
1 th people wait
2 th people wait
3 th people wait
4 th people wait
5 th people wait
7 th people wait
8 th people wait
6 th people wait
9 th people wait
10 th people wait
go on together!
相關(guān)文章
SpringCloud負載均衡spring-cloud-starter-loadbalancer解讀
這篇文章主要介紹了SpringCloud負載均衡spring-cloud-starter-loadbalancer使用方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2025-03-03
這篇文章主要介紹了Java Socket編程服務器響應客戶端實例代碼，具有一定借鑒價值,需要的朋友可以參考下2017-12-12
這篇文章主要介紹了HashSet底層竟然是HashMap實現(xiàn)問題，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2023-07-07
Java進階:Struts多模塊的技巧...2006-12-12
MyBatis是一個持久層框架,簡化JDBC操作,SpringBoot集成MyBatis,通過創(chuàng)建項目、準備數(shù)據(jù)、配置文件、實體類和接口,可以實現(xiàn)數(shù)據(jù)庫操作,使用@Mapper和@Select注解簡化接口實現(xiàn),測試類使用@SpringBootTest和@Test注解啟動,本文介紹Mybatis啟動過程,感興趣的朋友一起看看吧2025-03-03
詳解Java并發(fā)編程之volatile關(guān)鍵字
這篇文章主要為大家介紹了Java并發(fā)編程之volatile關(guān)鍵字，具有一定的參考價值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助2021-11-11
這篇文章主要介紹了Java的垃圾強制回收,結(jié)合實例形式分析了java垃圾強制回收的相關(guān)原理及實現(xiàn)方法,需要的朋友可以參考下2019-08-08
我們在編寫接口時會傳入復雜參數(shù)，如Map、Model等，這種類似的參數(shù)會有相應的參數(shù)解析器進行解析，并且最后會將解析出的值放到request域中，下面我們一起來探析一下其中的原理2022-09-09
spring boot+自定義 AOP 實現(xiàn)全局校驗的實例代碼
最近公司重構(gòu)項目，重構(gòu)為最熱的微服務框架 spring boot， 重構(gòu)的時候遇到幾個可以統(tǒng)一處理的問題。這篇文章主要介紹了spring boot+自定義 AOP 實現(xiàn)全局校驗 ,需要的朋友可以參考下2019-04-04
這篇文章主要介紹了Java 多個異常共享同一個異常處理器的方法,Java 的異常處理機制，在 Java 7 中有了非常大的改進。其中一個特性就是，支持多個異常共享同一個異常處理器。,需要的朋友可以參考下2019-06-06