溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
java多線程之CyclicBarrier的使用方法
public class CyclicBarrierTest {
public static void main(String[] args) {
ExecutorService service = Executors.newCachedThreadPool();
final CyclicBarrier cb = new CyclicBarrier(3);
for(int i=0;i<3;i++){
Runnable runnable = new Runnable(){
public void run(){
try {
Thread.sleep((long)(Math.random()*10000));
System.out.println("線程" + Thread.currentThread().getName() +
"即將到達集合地點1，當前已有" + (cb.getNumberWaiting()+1) + "個已經到達，" + (cb.getNumberWaiting()==2?"都到齊了，繼續走啊":"正在等候"));
cb.await();
Thread.sleep((long)(Math.random()*10000));
System.out.println("線程" + Thread.currentThread().getName() +
"即將到達集合地點2，當前已有" + (cb.getNumberWaiting()+1) + "個已經到達，" + (cb.getNumberWaiting()==2?"都到齊了，繼續走啊":"正在等候"));
cb.await();
Thread.sleep((long)(Math.random()*10000));
System.out.println("線程" + Thread.currentThread().getName() +
"即將到達集合地點3，當前已有" + (cb.getNumberWaiting() + 1) + "個已經到達，" + (cb.getNumberWaiting()==2?"都到齊了，繼續走啊":"正在等候"));
cb.await();
} catch (Exception e) {
e.printStackTrace();
}
}
};
service.execute(runnable);
}
service.shutdown();
}
}
運行結果如下：
線程pool-1-thread-3即將到達集合地點1，當前已有1個已經到達，正在等候 線程pool-1-thread-1即將到達集合地點1，當前已有2個已經到達，正在等候 線程pool-1-thread-2即將到達集合地點1，當前已有3個已經到達，都到齊了，繼續走啊 線程pool-1-thread-3即將到達集合地點2，當前已有1個已經到達，正在等候 線程pool-1-thread-1即將到達集合地點2，當前已有2個已經到達，正在等候 線程pool-1-thread-2即將到達集合地點2，當前已有3個已經到達，都到齊了，繼續走啊 線程pool-1-thread-1即將到達集合地點3，當前已有1個已經到達，正在等候 線程pool-1-thread-3即將到達集合地點3，當前已有2個已經到達，正在等候 線程pool-1-thread-2即將到達集合地點3，當前已有3個已經到達，都到齊了，繼續走啊
如有疑問請留言或者到本站社區交流討論，感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
