您好,登錄后才能下訂單哦!
本篇內容介紹了“Java中CyclicBarrier的使用方法”的有關知識,在實際案例的操作過程中,不少人都會遇到這樣的困境,接下來就讓小編帶領大家學習一下如何處理這些情況吧!希望大家仔細閱讀,能夠學有所成!
CyclicBarrier和CountDownLatch一樣在使用時也需要在構造方法中傳遞一個int類型的參數,但這個參數代表的含義和在使用上與CountDownLatch有所區別,這個參數代表的是攔截線程的數量,當線程調用CyclicBarrier中的await()方法時,就是告訴CyclicBarrier我已經攔截了當前線程,也就是此時調用await()方法的線程將被阻塞,線程中await()方法后面的代碼將不會執行,當前線程會一直等待,一到調用await()方法的線程數量與CyclicBarrier構造方法中參數的數量一致時,線程才會重新執行。下面我們看一下簡單的例子來演示一下CyclicBarrier的使用。
下面我們詳細分析一下輸出的信息。我們在CyclicBarrier構造方法中傳遞的參數是2也就是說它要攔截2個線程的await()方法后才會執行await()方法后面的邏輯。所以在調用await()方法之前線程是不會阻塞的。所以會出輸出開始、計時等信息,我們會發現當線程Thread-1已經執行完循環任務時,并沒有馬上輸出await()方法后面的代碼,而是此線程阻塞了,原因是Thread-0還沒有實現完,它還沒有執行await()方法,也就是說攔截的線程數量還沒有達到CyclicBarrier構造方法中傳遞數量,所以線程Thread-1就會一直阻塞直到Thread-0執行完循環并執行await()方法時,此時攔截的線程數量已經等于構造方法中的參數了,所以線程Thread-1才會恢復執行。這就是CyclicBarrier的使用。
CyclicBarrier與CountDownLatch的區別:
CountDownLatch阻塞的是主線程
CountDownLatch的計數器只能使用一次也就是只能遞減
CyclicBarrier阻塞的是子線程
CyclicBarrier的計數器可以使用reset()方法重置
CyclicBarrier還提供了另一個構造方法除了傳遞int類型的參數外,還可以傳遞一個Runnable類型。它的目的是,當線程的攔截的數量與構造方法的參數相等時,優先執行構造方法里的任務,然后在執行每個線程中await()方法后面的代碼。
“Java中CyclicBarrier的使用方法”的內容就介紹到這里了,感謝大家的閱讀。如果想了解更多行業相關的知識可以關注億速云網站,小編將為大家輸出更多高質量的實用文章!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。