Java線程：新特徵-障礙器

Java線程：新特徵-障礙器

 

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

 

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

 

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

/**
* Java線程：新特徵-障礙器
*
* @author leizhimin 2009-11-6 10:50:10
*/
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();
                }
        }
}

 

運行結果：

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

Process finished with exit code 0

 

從執行結果能夠看出，全部子任務完成的時候，主任務執行了，達到了控制的目標。