CyclicBarrier提供以下幾個方法：

　　await()：進入等待

　　getParties()：返回此barrier需要的線程數

　　reset()：將此barrier重置

　　以下是使用CyclicBarrier的一個例子：兩個線程分別在一個數組里放一個數，當這兩個線程都結束后，主線程算出數組里的數的和(這個例子比較無聊，我沒有想到更合適的例子)

　　Server is starting.

　　Component 1 initialized!

　　Component 3 initialized!

　　Component 2 initialized!

　　Server is up!

　　public class MainThread {

　　public static void main(String[] args)

　　throws InterruptedException, BrokenBarrierException, TimeoutException{

　　final int[] array = new int[2];

　　CyclicBarrier barrier = new CyclicBarrier(2,

　　new Runnable() {//在所有線程都到達Barrier時執(zhí)行

　　public void run() {

　　System.out.println("Total is:"+(array[0]+array[1]));

　　}

　　});

　　//啟動線程

　　new Thread(new ComponentThread(barrier, array, 0)).start();

　　new Thread(new ComponentThread(barrier, array, 1)).start();

　　}

　　}

　　public class ComponentThread implements Runnable{

　　CyclicBarrier barrier;

　　int ID;

　　int[] array;

　　public ComponentThread(CyclicBarrier barrier, int[] array, int ID) {

　　this.barrier = barrier;

　　this.ID = ID;

　　this.array = array;

　　}

　　public void run() {

　　try {

　　array[ID] = new Random().nextInt();

　　System.out.println(ID+ " generates:"+array[ID]);

　　//該線程完成了任務等在Barrier處

　　barrier.await();

　　} catch (BrokenBarrierException ex) {

　　ex.printStackTrace();

　　} catch (InterruptedException ex) {

　　ex.printStackTrace();

　　}

　　}

　　}

　　Exchanger:

　　顧名思義Exchanger讓兩個線程可以互換信息。用一個例子來解釋比較容易。例子中服務生線程往空的杯子里倒水，顧客線程從裝滿水的杯子里喝水，然后通過Exchanger雙方互換杯子，服務生接著往空杯子里倒水，顧客接著喝水，然后交換，如此周而復始。

　　class FillAndEmpty {

　　//初始化一個Exchanger，并規(guī)定可交換的信息類型是DataCup

　　Exchanger exchanger = new Exchanger();

　　Cup initialEmptyCup = ...; //初始化一個空的杯子

　　Cup initialFullCup = ...; //初始化一個裝滿水的杯子

　　//服務生線程

　　class Waiter implements Runnable {

　　public void run() {

　　Cup currentCup = initialEmptyCup;

　　try {

　　//往空的杯子里加水

　　currentCup.addWater();

　　//杯子滿后和顧客的空杯子交換

　　currentCup = exchanger.exchange(currentCup);

　　} catch (InterruptedException ex) { ... handle ... }

　　}

　　}

　　//顧客線程

　　class Customer implements Runnable {

　　public void run() {

　　DataCup currentCup = initialFullCup;

　　try {

　　//把杯子里的水喝掉

　　currentCup.drinkFromCup();

　　//將空杯子和服務生的滿杯子交換

　　currentCup = exchanger.exchange(currentCup);

　　} catch (InterruptedException ex) { ... handle ...}

　　}

　　}

　　void start() {

　　new Thread(new Waiter()).start();

　　new Thread(new Customer()).start();

　　}

　　}

　　6: BlockingQueue接口

　　BlockingQueue是一種特殊的Queue，若BlockingQueue是空的，從BlockingQueue取東西的操作將會被阻斷進入等待狀態(tài)直到BlocingkQueue進了新貨才會被喚醒。同樣，如果BlockingQueue是滿的任何試圖往里存東西的操作也會被阻斷進入等待狀態(tài)，直到BlockingQueue里有新的空間才會被喚醒繼續(xù)操作。BlockingQueue提供的方法主要有：

　　add(anObject): 把anObject加到BlockingQueue里，如果BlockingQueue可以容納返回true，否則拋出IllegalStateException異常。

　　offer(anObject)：把anObject加到BlockingQueue里，如果BlockingQueue可以容納返回true，否則返回false。

　　put(anObject)：把anObject加到BlockingQueue里，如果BlockingQueue沒有空間，調用此方法的線程被阻斷直到BlockingQueue里有新的空間再繼續(xù)。

　　poll(time)：取出BlockingQueue里排在首位的對象，若不能立即取出可等time參數規(guī)定的時間。取不到時返回null。

　　take()：取出BlockingQueue里排在首位的對象，若BlockingQueue為空，阻斷進入等待狀態(tài)直到BlockingQueue有新的對象被加入為止。

　　　　　　　2010年9月計算機等級考試成績查詢時間匯總

 　　　　　　 2011計算機等級考試二級JAVA學習精華匯總