現(xiàn)實生活中我們經(jīng)常會遇到這樣的情景，在進行某個活動前需要等待人全部都齊了才開始。例如吃飯時要等全家人都上座了才動筷子，旅游時要等全部人都到齊了才出發(fā)，比賽時要等運動員都上場后才開始。在JUC包中為我們提供了一個同步工具類能夠很好的模擬這類場景，它就是CyclicBarrier類。利用CyclicBarrier類可以實現(xiàn)一組線程相互等待，當所有線程都到達某個屏障點后再進行后續(xù)的操作。下圖演示了這一過程。

創(chuàng)新互聯(lián)公司始終致力于在企業(yè)網(wǎng)站建設領域發(fā)展。秉承“創(chuàng)新、求實、誠信、拼搏”的企業(yè)精神，致力為企業(yè)提供全面的網(wǎng)絡宣傳與技術(shù)應用整體策劃方案，為企業(yè)提供包括“網(wǎng)站建設、成都響應式網(wǎng)站建設公司、手機網(wǎng)站建設、微信網(wǎng)站建設、微信小程序、購物商城網(wǎng)站建設、平臺網(wǎng)站建設秉承"和諧、參與、激情"的文化，與客戶和合作伙伴齊心協(xié)力一起成長，共同發(fā)展。

在CyclicBarrier類的內(nèi)部有一個計數(shù)器，每個線程在到達屏障點的時候都會調(diào)用await方法將自己阻塞，此時計數(shù)器會減1，當計數(shù)器減為0的時候所有因調(diào)用await方法而被阻塞的線程將被喚醒。這就是實現(xiàn)一組線程相互等待的原理，下面我們先看看CyclicBarrier有哪些成員變量。

//同步操作鎖
private final ReentrantLock lock = new ReentrantLock();
//線程攔截器
private final Condition trip = lock.newCondition();
//每次攔截的線程數(shù)
private final int parties;
//換代前執(zhí)行的任務
private final Runnable barrierCommand;
//表示柵欄的當前代
private Generation generation = new Generation();
//計數(shù)器
private int count;

//靜態(tài)內(nèi)部類Generation
private static class Generation {
  boolean broken = false;
}

新聞名稱：Java并發(fā)系列之CyclicBarrier源碼分析-創(chuàng)新互聯(lián)
URL鏈接：http://www.rwnh.cn/article2/eppoc.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供品牌網(wǎng)站設計、網(wǎng)站排名、云服務器、虛擬主機、網(wǎng)站收錄、ChatGPT

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)