2011年計(jì)算機(jī)等考二級(jí)JAVA學(xué)習(xí)精華整理(48)

　　CyclicBarrier提供以下幾個(gè)方法：

　　await()：進(jìn)入等待

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

　　reset()：將此barrier重置

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

　　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() {//在所有線程都到達(dá)Barrier時(shí)執(zhí)行

　　public void run() {

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

　　}

　　});

　　//啟動(dòng)線程

　　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]);

　　//該線程完成了任務(wù)等在Barrier處

　　barrier.await();

　　} catch (BrokenBarrierException ex) {

　　ex.printStackTrace();

　　} catch (InterruptedException ex) {

　　ex.printStackTrace();

　　}

　　}

　　}

　　Exchanger:

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

　　class FillAndEmpty {

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

　　Exchanger exchanger = new Exchanger();

　　Cup initialEmptyCup = ...; //初始化一個(gè)空的杯子

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

　　//服務(wù)生線程

　　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();

　　//將空杯子和服務(wù)生的滿杯子交換

　　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取東西的操作將會(huì)被阻斷進(jìn)入等待狀態(tài)直到BlocingkQueue進(jìn)了新貨才會(huì)被喚醒。同樣，如果BlockingQueue是滿的任何試圖往里存東西的操作也會(huì)被阻斷進(jìn)入等待狀態(tài)，直到BlockingQueue里有新的空間才會(huì)被喚醒繼續(xù)操作。BlockingQueue提供的方法主要有：

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

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

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

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

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

　　　　　　　2010年9月計(jì)算機(jī)等級(jí)考試成績查詢時(shí)間匯總

 　　　　　　 2011計(jì)算機(jī)等級(jí)考試二級(jí)JAVA學(xué)習(xí)精華匯總