Java并發(fā)編程之柵欄(CyclicBarrier)實(shí)例介紹
柵欄類(lèi)似閉鎖,但是它們是有區(qū)別的.
1.閉鎖用來(lái)等待事件，而柵欄用于等待其他線程.什么意思呢?就是說(shuō)閉鎖用來(lái)等待的事件就是countDown事件,只有該countDown事件執(zhí)行后所有之前在等待的線程才有可能繼續(xù)執(zhí)行;而柵欄沒(méi)有類(lèi)似countDown事件控制線程的執(zhí)行,只有線程的await方法能控制等待的線程執(zhí)行.
2.CyclicBarrier強(qiáng)調(diào)的是n個(gè)線程，大家相互等待，只要有一個(gè)沒(méi)完成，所有人都得等著。
場(chǎng)景分析:10個(gè)人去春游,規(guī)定達(dá)到一個(gè)地點(diǎn)后才能繼續(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(); // 大家等待最后一個(gè)線程到達(dá)
} 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負(fù)載均衡spring-cloud-starter-loadbalancer解讀
這篇文章主要介紹了SpringCloud負(fù)載均衡spring-cloud-starter-loadbalancer使用方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2025-03-03
Java Socket編程服務(wù)器響應(yīng)客戶端實(shí)例代碼
這篇文章主要介紹了Java Socket編程服務(wù)器響應(yīng)客戶端實(shí)例代碼，具有一定借鑒價(jià)值,需要的朋友可以參考下2017-12-12
HashSet底層竟然是HashMap實(shí)現(xiàn)問(wèn)題
這篇文章主要介紹了HashSet底層竟然是HashMap實(shí)現(xiàn)問(wèn)題，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-07-07
Java進(jìn)階:Struts多模塊的技巧...2006-12-12
Mybatis 簡(jiǎn)單啟動(dòng)過(guò)程入門(mén)詳解
MyBatis是一個(gè)持久層框架,簡(jiǎn)化JDBC操作,SpringBoot集成MyBatis,通過(guò)創(chuàng)建項(xiàng)目、準(zhǔn)備數(shù)據(jù)、配置文件、實(shí)體類(lèi)和接口,可以實(shí)現(xiàn)數(shù)據(jù)庫(kù)操作,使用@Mapper和@Select注解簡(jiǎn)化接口實(shí)現(xiàn),測(cè)試類(lèi)使用@SpringBootTest和@Test注解啟動(dòng),本文介紹Mybatis啟動(dòng)過(guò)程,感興趣的朋友一起看看吧2025-03-03
詳解Java并發(fā)編程之volatile關(guān)鍵字
這篇文章主要為大家介紹了Java并發(fā)編程之volatile關(guān)鍵字，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來(lái)幫助2021-11-11
這篇文章主要介紹了Java的垃圾強(qiáng)制回收,結(jié)合實(shí)例形式分析了java垃圾強(qiáng)制回收的相關(guān)原理及實(shí)現(xiàn)方法,需要的朋友可以參考下2019-08-08
SpringBoot復(fù)雜參數(shù)應(yīng)用詳細(xì)講解
我們?cè)诰帉?xiě)接口時(shí)會(huì)傳入復(fù)雜參數(shù)，如Map、Model等，這種類(lèi)似的參數(shù)會(huì)有相應(yīng)的參數(shù)解析器進(jìn)行解析，并且最后會(huì)將解析出的值放到request域中，下面我們一起來(lái)探析一下其中的原理2022-09-09
spring boot+自定義 AOP 實(shí)現(xiàn)全局校驗(yàn)的實(shí)例代碼
最近公司重構(gòu)項(xiàng)目，重構(gòu)為最熱的微服務(wù)框架 spring boot， 重構(gòu)的時(shí)候遇到幾個(gè)可以統(tǒng)一處理的問(wèn)題。這篇文章主要介紹了spring boot+自定義 AOP 實(shí)現(xiàn)全局校驗(yàn) ,需要的朋友可以參考下2019-04-04
Java 多個(gè)異常共享同一個(gè)異常處理器的方法
這篇文章主要介紹了Java 多個(gè)異常共享同一個(gè)異常處理器的方法,Java 的異常處理機(jī)制，在 Java 7 中有了非常大的改進(jìn)。其中一個(gè)特性就是，支持多個(gè)異常共享同一個(gè)異常處理器。,需要的朋友可以參考下2019-06-06