【轉(zhuǎn)】-Java并發(fā)之CyclicBarrier

Java并發(fā)之CyclicBarrier

? 該博客轉(zhuǎn)載自?巴蜀碼哥? ** 的?Java并發(fā)之CyclicBarrier**

barrier(屏障)與互斥量、讀寫(xiě)鎖、自旋鎖不同，它不是用來(lái)保護(hù)臨界區(qū)的。相反，它跟條件變量一樣，是用來(lái)協(xié)同多線程一起工作的。

條件變量是多線程間傳遞狀態(tài)的改變來(lái)達(dá)到協(xié)同工作的效果。屏障是多線程各自做自己的工作，如果某一線程完成了工作，就等待在屏障那里，直到其他線程的工作都完成了，再一起做別的事。舉個(gè)通俗的例子：

對(duì)于條件變量。在接力賽跑里，1號(hào)隊(duì)員開(kāi)始跑的時(shí)候，2，3，4號(hào)隊(duì)員都站著不動(dòng)，直到1號(hào)隊(duì)員跑完一圈，把接力棒給2號(hào)隊(duì)員，2號(hào)隊(duì)員收到接力棒后就可以跑了，跑完再給3號(hào)隊(duì)員。這里這個(gè)接力棒就相當(dāng)于條件變量，條件滿足后就可以由下一個(gè)隊(duì)員(線程)跑。
對(duì)于屏障：在百米賽跑里，比賽沒(méi)開(kāi)始之前，每個(gè)運(yùn)動(dòng)員都在賽場(chǎng)上自由活動(dòng)，有的熱身，有的喝水，有的跟教練談?wù)摗１荣惪扉_(kāi)始時(shí)，準(zhǔn)備完畢的運(yùn)動(dòng)員就預(yù)備在起跑線上，如果有個(gè)運(yùn)動(dòng)員還沒(méi)準(zhǔn)備完(除去特殊情況)，他們就一直等，直到運(yùn)動(dòng)員都在起跑線上，裁判喊口號(hào)后再開(kāi)始跑。這里的起跑線就是屏障，做完準(zhǔn)備工作的運(yùn)動(dòng)員都等在起跑線，直到其他運(yùn)動(dòng)員也把準(zhǔn)備工作做完。

java.util.concurrent.CyclicBarrier類(lèi)是一個(gè)同步機(jī)制。它可以通過(guò)一些算法來(lái)同步線程處理的過(guò)程。換言之，就是所有的線程必須等待對(duì)方，直到所有的線程到達(dá)屏障，然后繼續(xù)運(yùn)行。之所以叫做“循環(huán)屏障”，是因?yàn)檫@個(gè)屏障可以被重復(fù)使用。

CyclicBarrier有兩個(gè)構(gòu)造參數(shù)，分別是：

CyclicBarrier(int parties)

創(chuàng)建一個(gè)新的 CyclicBarrier，它將在給定數(shù)量的參與者（線程）處于等待狀態(tài)時(shí)啟動(dòng)，但它不會(huì)在啟動(dòng) barrier 時(shí)執(zhí)行預(yù)定義的操作。
??CyclicBarrier(int parties, Runnable barrierAction)

創(chuàng)建一個(gè)新的 CyclicBarrier，它將在給定數(shù)量的參與者（線程）處于等待狀態(tài)時(shí)啟動(dòng)，并在啟動(dòng) barrier 時(shí)執(zhí)行給定的屏障操作，該操作由最后一個(gè)進(jìn)入 barrier 的線程執(zhí)行。

讓線程在CyclicBarrier中等待

有兩個(gè)方法可以讓線程在CyclicBarrier處等待：

barrier.await();

barrier.await(10, TimeUnit.SECONDS);
??
第二個(gè)方法指線程等待的超時(shí)時(shí)間，當(dāng)出現(xiàn)等待超時(shí)的時(shí)候，當(dāng)前線程會(huì)被釋放,但會(huì)像其他線程傳播出BrokenBarrierException異常。

所有線程在CyclicBarrier等待，是指：

   ? 最后一個(gè)線程到達(dá)（調(diào)用await方法）

   ? 一個(gè)線程被被另外一個(gè)線程中斷（另外一個(gè)線程調(diào)用了這個(gè)現(xiàn)場(chǎng)的interrupt()方法）

   ? 其中一個(gè)等待的線程被中斷

   ? 其中一個(gè)等待的線程超時(shí)

   ? 一個(gè)外部的線程調(diào)用了CyclicBarrier.reset()方法。

下面以5個(gè)線程模擬5個(gè)運(yùn)動(dòng)員。運(yùn)動(dòng)員在賽跑的時(shí)候都會(huì)準(zhǔn)備一段時(shí)間，當(dāng)裁判發(fā)現(xiàn)所有的運(yùn)動(dòng)員都準(zhǔn)備完畢的時(shí)候，就舉起發(fā)令槍?zhuān)荣愰_(kāi)始。

package thread;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
/**
* 模擬運(yùn)動(dòng)員
**/
public class MyThread extends Thread {
    private CyclicBarrier cyclicBarrier;
    private String name;

    public MyThread(CyclicBarrier cyclicBarrier, String name) {
        super();
        this.cyclicBarrier = cyclicBarrier;
        this.name = name;
    }

    @Override
    public void run() {
        System.out.println(name + "開(kāi)始準(zhǔn)備");
        try {
            Thread.currentThread().sleep(5000);
            System.out.println(name + "準(zhǔn)備完畢！等待發(fā)令槍");
            try {
                cyclicBarrier.await();
            } catch (BrokenBarrierException e) {            
                e.printStackTrace();
            }
        } catch (InterruptedException e) {

            e.printStackTrace();
        }
    }
}
//測(cè)試類(lèi)
public class Test {
    public static void main(String[] args) {
        CyclicBarrier barrier = new CyclicBarrier(5, new Runnable() {

            @Override
            public void run() {
                System.out.println("發(fā)令槍響了，跑！");

            }
        });
        for (int i = 0; i < 5; i++) {
            new MyThread(barrier, "運(yùn)動(dòng)員" + i + "號(hào)").start();

        }

    }

}

當(dāng)執(zhí)行測(cè)試類(lèi)的時(shí)候，輸出如下的結(jié)果（順序每次執(zhí)行可能會(huì)不太一樣）：

運(yùn)動(dòng)員1號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員3號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員2號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員0號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員4號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員1號(hào)準(zhǔn)備完畢！等待發(fā)令槍
運(yùn)動(dòng)員4號(hào)準(zhǔn)備完畢！等待發(fā)令槍
運(yùn)動(dòng)員0號(hào)準(zhǔn)備完畢！等待發(fā)令槍
運(yùn)動(dòng)員3號(hào)準(zhǔn)備完畢！等待發(fā)令槍
運(yùn)動(dòng)員2號(hào)準(zhǔn)備完畢！等待發(fā)令槍
發(fā)令槍響了，跑!

從輸出可以看到,當(dāng)給定數(shù)量的參與者（線程）調(diào)用了await()方法之后，屏障放開(kāi)，CyclicBarrier中的屏障動(dòng)作被觸發(fā)了。如果沒(méi)有達(dá)到指定的數(shù)量，就會(huì)一直被阻塞。

Barrier被破壞

BrokenBarrierException如果在參與者（線程）在等待的過(guò)程中，Barrier被破壞，就會(huì)拋出BrokenBarrierException。可以用isBroken()方法檢測(cè)Barrier是否被破壞。

1.如果有線程已經(jīng)處于等待狀態(tài)，調(diào)用reset方法會(huì)導(dǎo)致已經(jīng)在等待的線程出現(xiàn)??BrokenBarrierException??異常。并且由于出現(xiàn)了??BrokenBarrierException?? ，將會(huì)導(dǎo)致始終無(wú)法等待。

比如，五個(gè)運(yùn)動(dòng)員，其中一個(gè)在等待發(fā)令槍的過(guò)程中錯(cuò)誤地接收到裁判傳過(guò)來(lái)的指令，導(dǎo)致這個(gè)運(yùn)動(dòng)員以為今天比賽取消就離開(kāi)了賽場(chǎng)。但是其他運(yùn)動(dòng)員都領(lǐng)會(huì)的裁判正確的指令，剩余的運(yùn)動(dòng)員在起跑線上無(wú)限地等待下去，并且裁判看到運(yùn)動(dòng)員沒(méi)有到齊，也不會(huì)打發(fā)令槍。

package thread;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

public class MyThread extends Thread {
    private CyclicBarrier cyclicBarrier;
    private String name;
    private int ID;

    public MyThread(CyclicBarrier cyclicBarrier, String name,int ID) {
        super();
        this.cyclicBarrier = cyclicBarrier;
        this.name = name;
        this.ID=ID;

    }
    @Override
    public void run() {
        System.out.println(name + "開(kāi)始準(zhǔn)備");
        try {
            Thread.sleep(ID*1000);  //不同運(yùn)動(dòng)員準(zhǔn)備時(shí)間不一樣，方便模擬不同情況
            System.out.println(name + "準(zhǔn)備完畢！在起跑線等待發(fā)令槍");
            try {
                cyclicBarrier.await();
                System.out.println(name + "跑完了路程！");
            } catch (BrokenBarrierException e) {
                e.printStackTrace();
                System.out.println(name+"看不見(jiàn)起跑線了");
            }
            System.out.println(name+"退場(chǎng)！");
        } catch (InterruptedException e) {

            e.printStackTrace();
        }

    }

}
public class Test {

    public static void main(String[] args) throws InterruptedException {
        CyclicBarrier barrier = new CyclicBarrier(5, new Runnable() {
            @Override
            public void run() {
                System.out.println("發(fā)令槍響了，跑！");

            }
        });

        for (int i = 0; i < 5; i++) {
            new MyThread(barrier, "運(yùn)動(dòng)員" + i + "號(hào)", i).start();
        }
        Thread.sleep(1000);
        barrier.reset();
    }

}

輸出結(jié)果：

運(yùn)動(dòng)員0號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員1號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員2號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員3號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員4號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員0號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
運(yùn)動(dòng)員1號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
java.util.concurrent.BrokenBarrierException
運(yùn)動(dòng)員0號(hào)看不見(jiàn)起跑線了
運(yùn)動(dòng)員0號(hào)退場(chǎng)！
    at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:250)
    at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:362)
    at thread.MyThread.run(MyThread.java:27)
運(yùn)動(dòng)員2號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
運(yùn)動(dòng)員3號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
運(yùn)動(dòng)員4號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍

從輸出可以看到，運(yùn)動(dòng)員0號(hào)在等待的過(guò)程中，主線程調(diào)用了reset方法，導(dǎo)致拋出BrokenBarrierException異常。但是其他線程并沒(méi)有受到影響，它們會(huì)一直等待下去，從而一直被阻塞。

2.如果在等待的過(guò)程中，線程被中斷，也會(huì)拋出??BrokenBarrierException??異常，并且這個(gè)異常會(huì)傳播到其他所有的線程。

package thread;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.CyclicBarrier;

public class Test {
static   Map<Integer,Thread>   threads=new HashMap<>();
    public static void main(String[] args) throws InterruptedException {
        CyclicBarrier barrier = new CyclicBarrier(5, new Runnable() {
            @Override
            public void run() {
                System.out.println("發(fā)令槍響了，跑！");

            }
        });

        for (int i = 0; i < 5; i++) {
        MyThread t = new MyThread(barrier, "運(yùn)動(dòng)員" + i + "號(hào)", i);
            threads.put(i, t);
            t.start();
        }
        Thread.sleep(3000);
        threads.get(1).interrupt();
    }

}

輸出：

運(yùn)動(dòng)員0號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員2號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員3號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員1號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員0號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
運(yùn)動(dòng)員4號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員1號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
運(yùn)動(dòng)員2號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
運(yùn)動(dòng)員3號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
java.lang.InterruptedException
運(yùn)動(dòng)員3號(hào)看不見(jiàn)起跑線了
運(yùn)動(dòng)員3號(hào)退場(chǎng)！
運(yùn)動(dòng)員2號(hào)看不見(jiàn)起跑線了
運(yùn)動(dòng)員2號(hào)退場(chǎng)！
運(yùn)動(dòng)員0號(hào)看不見(jiàn)起跑線了
運(yùn)動(dòng)員0號(hào)退場(chǎng)！
    at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014)
    at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2048)
    at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:234)
    at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:362)
    at thread.MyThread.run(MyThread.java:27)
java.util.concurrent.BrokenBarrierException
    at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:250)
    at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:362)
    at thread.MyThread.run(MyThread.java:27)
java.util.concurrent.BrokenBarrierException
    at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:250)
    at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:362)
    at thread.MyThread.run(MyThread.java:27)
java.util.concurrent.BrokenBarrierException
    at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:250)
    at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:362)
    at thread.MyThread.run(MyThread.java:27)
運(yùn)動(dòng)員4號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
java.util.concurrent.BrokenBarrierException
    at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:207)
    at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:362)
    at thread.MyThread.run(MyThread.java:27)
運(yùn)動(dòng)員4號(hào)看不見(jiàn)起跑線了
運(yùn)動(dòng)員4號(hào)退場(chǎng)！

從輸出可以看到，其中一個(gè)線程被中斷，那么所有的運(yùn)動(dòng)員都退場(chǎng)了。

3.如果在執(zhí)行屏障操作過(guò)程中發(fā)生異常，則該異常將傳播到當(dāng)前線程中，其他線程會(huì)拋出BrokenBarrierException，屏障被損壞。

這個(gè)就好比運(yùn)動(dòng)員都沒(méi)有問(wèn)題，而是裁判出問(wèn)題了。裁判權(quán)力比較大，直接告訴所有的運(yùn)動(dòng)員，今天不比賽了，你們都回家吧！

package thread;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.CyclicBarrier;

public class Test {
    static Map<Integer, Thread> threads = new HashMap<>();

    public static void main(String[] args) throws InterruptedException {
        CyclicBarrier barrier = new CyclicBarrier(5, new Runnable() {
            @Override
            public void run() {
                String str = null;
                str.substring(0, 1);
                System.out.println("發(fā)令槍響了，跑！");

            }
        });

        for (int i = 0; i < 5; i++) {
            MyThread t = new MyThread(barrier, "運(yùn)動(dòng)員" + i + "號(hào)", i);
            threads.put(i, t);
            t.start();
        }

    }

}

輸出：

運(yùn)動(dòng)員0號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員3號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員2號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員1號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員4號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員0號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
運(yùn)動(dòng)員1號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
運(yùn)動(dòng)員2號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
運(yùn)動(dòng)員3號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
運(yùn)動(dòng)員4號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
Exception in thread "Thread-4" java.util.concurrent.BrokenBarrierException
    at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:250)
    at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:362)
    at thread.MyThread.run(MyThread.java:27)
運(yùn)動(dòng)員0號(hào)看不見(jiàn)起跑線了
運(yùn)動(dòng)員0號(hào)退場(chǎng)！
java.util.concurrent.BrokenBarrierException
    at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:250)
    at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:362)
    at thread.MyThread.run(MyThread.java:27)
運(yùn)動(dòng)員3號(hào)看不見(jiàn)起跑線了
運(yùn)動(dòng)員3號(hào)退場(chǎng)！
java.util.concurrent.BrokenBarrierException
    at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:250)
    at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:362)
    at thread.MyThread.run(MyThread.java:27)
運(yùn)動(dòng)員1號(hào)看不見(jiàn)起跑線了
運(yùn)動(dòng)員1號(hào)退場(chǎng)！
java.lang.NullPointerException
    at thread.Test$1.run(Test.java:15)
    at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:220)
    at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:362)
    at thread.MyThread.run(MyThread.java:27)
java.util.concurrent.BrokenBarrierException
    at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:250)
    at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:362)
    at thread.MyThread.run(MyThread.java:27)
運(yùn)動(dòng)員2號(hào)看不見(jiàn)起跑線了
運(yùn)動(dòng)員2號(hào)退場(chǎng)！

可以看到，如果在執(zhí)行屏障動(dòng)作的過(guò)程中出現(xiàn)異常，那么所有的線程都會(huì)拋出BrokenBarrierException異常。

4.如果超出指定的等待時(shí)間，當(dāng)前線程會(huì)拋出 TimeoutException 異常，其他線程會(huì)拋出BrokenBarrierException異常。

package thread;

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

public class MyThread extends Thread {
    private CyclicBarrier cyclicBarrier;
    private String name;
    private int ID;

    public MyThread(CyclicBarrier cyclicBarrier, String name, int ID) {
        super();
        this.cyclicBarrier = cyclicBarrier;
        this.name = name;
        this.ID = ID;

    }

    @Override
    public void run() {
        System.out.println(name + "開(kāi)始準(zhǔn)備");
        try {
            Thread.sleep(ID * 1000);
            System.out.println(name + "準(zhǔn)備完畢！在起跑線等待發(fā)令槍");
            try {
                try {
                    cyclicBarrier.await(ID * 1000, TimeUnit.MILLISECONDS);
                } catch (TimeoutException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
                System.out.println(name + "跑完了路程！");
            } catch (BrokenBarrierException e) {
                e.printStackTrace();
                System.out.println(name + "看不見(jiàn)起跑線了");
            }
            System.out.println(name + "退場(chǎng)！");
        } catch (InterruptedException e) {

            e.printStackTrace();
        }

    }

}

輸出：

運(yùn)動(dòng)員0號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員2號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員3號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員1號(hào)開(kāi)始準(zhǔn)備
運(yùn)動(dòng)員0號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
運(yùn)動(dòng)員4號(hào)開(kāi)始準(zhǔn)備
java.util.concurrent.TimeoutException運(yùn)動(dòng)員0號(hào)跑完了路程！
運(yùn)動(dòng)員0號(hào)退場(chǎng)！

    at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:257)
    at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:435)
    at thread.MyThread.run(MyThread.java:29)
運(yùn)動(dòng)員1號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
java.util.concurrent.BrokenBarrierException
    at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:207)
    at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:435)
    at thread.MyThread.run(MyThread.java:29)
運(yùn)動(dòng)員1號(hào)看不見(jiàn)起跑線了
運(yùn)動(dòng)員1號(hào)退場(chǎng)！
運(yùn)動(dòng)員2號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
java.util.concurrent.BrokenBarrierException
運(yùn)動(dòng)員2號(hào)看不見(jiàn)起跑線了
運(yùn)動(dòng)員2號(hào)退場(chǎng)！
    at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:207)
    at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:435)
    at thread.MyThread.run(MyThread.java:29)
運(yùn)動(dòng)員3號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
java.util.concurrent.BrokenBarrierException
    at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:207)
    at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:435)
    at thread.MyThread.run(MyThread.java:29)
運(yùn)動(dòng)員3號(hào)看不見(jiàn)起跑線了
運(yùn)動(dòng)員3號(hào)退場(chǎng)！
運(yùn)動(dòng)員4號(hào)準(zhǔn)備完畢！在起跑線等待發(fā)令槍
java.util.concurrent.BrokenBarrierException
運(yùn)動(dòng)員4號(hào)看不見(jiàn)起跑線了
運(yùn)動(dòng)員4號(hào)退場(chǎng)！
    at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:207)
    at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:435)
    at thread.MyThread.run(MyThread.java:29)

從輸出可以看到，如果其中一個(gè)參與者拋出TimeoutException，其他參與者會(huì)拋出BrokenBarrierException。

posted @ 2024-07-10 09:41 booleandev 閱讀(13) 評(píng)論(0) 收藏舉報(bào)

刷新頁(yè)面返回頂部

Jantor的博客

【轉(zhuǎn)】-Java并發(fā)之CyclicBarrier

Java并發(fā)之CyclicBarrier

讓線程在CyclicBarrier中等待

Barrier被破壞

公告