java barrier是什么,讓我們一起了解一下?
barrier是Java中的CyclicBarrier,是可循環使用的屏障,要做的事情就是讓一組線程到達一個屏障時被阻塞,直到最后一個線程到達屏障時,屏障才會開門,所有被屏障攔截的線程才會繼續運行。
CyclicBarrier有什么常用方法?
首先在所有參與者都已經在此 barrier 上調用?await方法之前,將被一直等待。如果當前線程不是將到達的最后一個線程,出于調度目的,將禁用它,且在發生以下情況之一前,該線程將一直處于休眠狀態。
最后一個線程到達,或者其他某個線程中斷當前線程,或者其他某個線程中斷另一個等待線程,或者其他某個線程在等待 barrier 時超時,或者其他某個線程在此 barrier 上調用?reset()。
如果當前線程在進入此方法時已經設置了該線程的中斷狀態,或者在等待時被中斷,則拋出?InterruptedException,并且清除當前線程的已中斷狀態。
如果在線程處于等待狀態時 barrier 被?reset(),或者在調用?await?時 barrier?被損壞,抑或任意一個線程正處于等待狀態,則出?BrokenBarrierException?異常。
如果任何線程在等待時被中斷,則其他所有等待線程都將拋出?BrokenBarrierException?異常,并將 barrier 置于損壞狀態。
如果當前線程是最后一個將要到達的線程,并且構造方法中提供了一個非空的屏障操作,則在允許其他線程繼續運行之前,當前線程將運行該操作。如果在執行屏障操作過程中發生異常,則該異常將傳播到當前線程中,并將 barrier 置于損壞狀態。
示例代碼如下:
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("門開了"); }
以上就是小編今天的分享了,希望可以幫助到大家。