java barrier是什么，讓我們一起了解一下？

barrier是Java中的CyclicBarrier，是可循環(huán)使用的屏障，要做的事情就是讓一組線程到達一個屏障時被阻塞，直到最后一個線程到達屏障時，屏障才會開門，所有被屏障攔截的線程才會繼續(xù)運行。

CyclicBarrier有什么常用方法？

首先在所有參與者都已經(jīng)在此 barrier 上調(diào)用?await方法之前，將被一直等待。如果當(dāng)前線程不是將到達的最后一個線程，出于調(diào)度目的，將禁用它，且在發(fā)生以下情況之一前，該線程將一直處于休眠狀態(tài)。

最后一個線程到達，或者其他某個線程中斷當(dāng)前線程，或者其他某個線程中斷另一個等待線程，或者其他某個線程在等待 barrier 時超時，或者其他某個線程在此 barrier 上調(diào)用?reset()。

如果當(dāng)前線程在進入此方法時已經(jīng)設(shè)置了該線程的中斷狀態(tài)，或者在等待時被中斷，則拋出?InterruptedException，并且清除當(dāng)前線程的已中斷狀態(tài)。

如果在線程處于等待狀態(tài)時 barrier 被?reset()，或者在調(diào)用?await?時 barrier?被損壞，抑或任意一個線程正處于等待狀態(tài)，則出?BrokenBarrierException?異常。

如果任何線程在等待時被中斷，則其他所有等待線程都將拋出?BrokenBarrierException?異常，并將 barrier 置于損壞狀態(tài)。

如果當(dāng)前線程是最后一個將要到達的線程，并且構(gòu)造方法中提供了一個非空的屏障操作，則在允許其他線程繼續(xù)運行之前，當(dāng)前線程將運行該操作。如果在執(zhí)行屏障操作過程中發(fā)生異常，則該異常將傳播到當(dāng)前線程中，并將 barrier 置于損壞狀態(tài)。

示例代碼如下：

public?static?void?main(String[]?args)?{
????CyclicBarrier?c?=?new?CyclicBarrier(2);
????Thread?t1?=?new?Thread(){
????????@Override
????????public?void?run()?{
????????????System.out.println("我到了");
????????????try?{
????????????????c.await();
????????????}catch?(Exception?e){
????????????????e.printStackTrace();
????????????}
????????}
????};
????t1.start();
????System.out.println("我到了");
????try?{
????????c.await();
????}catch?(Exception?e){
????????e.printStackTrace();
????}
????System.out.println("門開了");
}

以上就是小編今天的分享了，希望可以幫助到大家。