? ? Phaser是一個更加彈性的同步屏障。和同步屏障一樣，一個phaser使得一組線程在

屏障上等待，在最后一個線程到達之后，這些線程才得以繼續執行。phaser也提供了和barrier

action等價的操作。

????和同步屏障協同固定數目的線程不同，一個phaser能夠協調不定數目的線程，這些

線程可以在任何時候注冊。

示例代碼：

????下面的例子創建了3個線程，打印一些字母，但是線程創建好后并不立刻執行，而是在主程序中

對其進行控制，3秒鐘后所有進程同時開始執行

import?java.util.concurrent.Phaser;public?class?MyTest?{public?static?void?main(String[]?args)?{Phaser?phaser?=?new?Phaser(3)?{//?共有3個工作線程，因此在構造函數中賦值為3@Overrideprotected?boolean?onAdvance(int?phase,?int?registeredParties)?{System.out.println("\n=========華麗的分割線=============");return?registeredParties?==?0;}};System.out.println("程序開始執行");char?a?=?'a';for?(int?i?=?0;?i?<?3;?i++)?{?//?創建并啟動3個線程new?MyThread((char)?(a?+?i),?phaser).start();}while?(!phaser.isTerminated())?{//?只要phaser不終結，主線程就循環等待Thread.yield();}System.out.println("程序結束");} }class?MyThread?extends?Thread?{private?char?c;private?Phaser?phaser;public?MyThread(char?c,?Phaser?phaser)?{this.c?=?c;this.phaser?=?phaser;}@Overridepublic?void?run()?{while?(!phaser.isTerminated())?{for?(int?i?=?0;?i?<?10;?i++)?{?//?將當前字母打印10次System.out.print(c?+?"?");}//?打印完當前字母后，將其更新為其后第三個字母，例如b更新為e，用于下一階段打印c?=?(char)?(c?+?3);if?(c?>?'z')?{//?如果超出了字母z，則在phaser中動態減少一個線程，并退出循環結束本線程phaser.arriveAndDeregister();break;}?else?{//?反之，等待其他線程到達階段終點，再一起進入下一個階段phaser.arriveAndAwaitAdvance();}}} }

轉載于:https://blog.51cto.com/12222886/2062974

《新程序員》：云原生和全面數字化實踐50位技術專家共同創作，文字、視頻、音頻交互閱讀

總結

以上是生活随笔為你收集整理的Java线程与并发编程实践----同步器(Phaser)的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。