Java5中，添加了障礙器類，為了適應一種新的設計需求，比如一個大型的任務，常常需要分配好多子任務去執行，只有當所有子任務都執行完成時候，才能執行主任務，這時候，就可以選擇障礙器了。

????????障礙器是多線程并發控制的一種手段，用法很簡單。下面給個例子：

import?java.util.concurrent.BrokenBarrierException;?? import?java.util.concurrent.CyclicBarrier;??/**?*?Java線程：新特征-障礙器?*/?? public?class?Test?{??public?static?void?main(String[]?args){??//創建障礙器，并設置MainTask為所有定數量的線程都達到障礙點時候所要執行的任務(Runnable)??CyclicBarrier?cb?=?new?CyclicBarrier(7,new?MainTask());??new?SubTask("A",?cb).start();??new?SubTask("B",?cb).start();??new?SubTask("C",?cb).start();??new?SubTask("D",?cb).start();??new?SubTask("E",?cb).start();??new?SubTask("F",?cb).start();??new?SubTask("G",?cb).start();??}?? }?? //主任務?? class?MainTask?implements?Runnable?{??public?void?run()?{??System.out.println(">>>>主任務執行了！<<<<");??}?? }?? //子任務?? class?SubTask?extends?Thread?{??private?String?name;??private?CyclicBarrier?cb;??SubTask(String?name,?CyclicBarrier?cb)?{??this.name?=?name;??this.cb?=?cb;??}??public?void?run(){??System.out.println("[子任務"+name+"]開始執行了！");??for(int?i=0;i<999999;i++);//模擬耗時的任務??System.out.println("[子任務"?+?name?+"]開始執行完成了，并通知障礙器已經完成！");??try?{??//通知障礙器已經完成??cb.await();??}?catch(InterruptedException?e)?{??e.printStackTrace();??}?catch(BrokenBarrierException?e)?{??e.printStackTrace();??}??}?? }??

????????執行結果：

[子任務B]開始執行了！?? [子任務A]開始執行了！?? [子任務D]開始執行了！?? [子任務A]開始執行完成了，并通知障礙器已經完成！?? [子任務D]開始執行完成了，并通知障礙器已經完成！?? [子任務C]開始執行了！?? [子任務C]開始執行完成了，并通知障礙器已經完成！?? [子任務F]開始執行了！?? [子任務B]開始執行完成了，并通知障礙器已經完成！?? [子任務E]開始執行了！?? [子任務F]開始執行完成了，并通知障礙器已經完成！?? [子任務G]開始執行了！?? [子任務E]開始執行完成了，并通知障礙器已經完成！?? [子任務G]開始執行完成了，并通知障礙器已經完成！?? >>>>主任務執行了！<<<<??

????????從執行結果可以看出，所有子任務完成的時候，主任務執行了，達到了控制的目標。
?

總結

以上是生活随笔為你收集整理的Java线程详解(18)-障碍器的全部內容，希望文章能夠幫你解決所遇到的問題。

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