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("門開了"); }
以上就是小編今天的分享了,希望可以幫助到大家。