Cyh的博客

Email:kissyan4916@163.com

posts - 26, comments - 19, trackbacks - 0, articles - 220

線程--CyclicBarrier

Posted on 2009-12-23 23:38 啥都寫點閱讀(1786) 評論(0) 編輯收藏所屬分類: J2SE

本例介紹第三個同步裝置：CyclicBarrier，它維護一個計數器，與CountDownLatch不同的是，等待這個CyclicBarrier的線程必須等到計數器到達某個值時，才可以繼續。CyclicBarrier就像它名字的意思一樣，可看成是個障礙，所有的線程必須到齊后才能一起通過這個障礙。本例實現一個數組相鄰元素的加法，一個線程給數組的第一個元素賦值，然后等待其他線程給數組第二個元素賦值，然后將第一個元素和第二個元素相加。

構造CyclicBarrier對象時，需要指定計數器的目標值，計數器的初始值為0.還可以在構造方法中帶一個Runnable參數，表示當計數器到達目標值時，在等待CyclicBarrier的線程被喚醒之前，指定該Runnable任務。

CyclicBarrier的await方法使當前線程進入等待狀態，計數器加1，當計數器到達目標值時，當前線程被喚醒。

import java.util.Random;

import java.util.concurrent.CyclicBarrier;

/**

* CyclicBarrier類似于CountDownLatch也是個計數器，

* 不同的是CyclicBarrier數的是調用了CyclicBarrier.await()進入等待的線程數，

* 當線程數達到了CyclicBarrier初始時規定的數目時，所有進入等待狀態的線程被喚醒并繼續。

* CyclicBarrier就象它名字的意思一樣，可看成是個障礙，

* 所有的線程必須到齊后才能一起通過這個障礙。

* CyclicBarrier初始時還可帶一個Runnable的參數，

* 此Runnable任務在CyclicBarrier的數目達到后，所有其它線程被喚醒前被執行。

public class CyclicBarrierTest {

public static 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(100);

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

// 在這里等待Barrier處

System.out.println("Component " + ID + " sleep

");

barrier.await();

System.out.println("Component " + ID + " awaked

");

// 計算數據數組中的當前值和后續值

int result = array[ID] + array[ID + 1];

System.out.println("Component " + ID + " result: " + result);

} catch (Exception ex) {

}

/**

* 測試CyclicBarrier的用法

public static void testCyclicBarrier() {

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

CyclicBarrier barrier = new CyclicBarrier(2, new Runnable() {

// 在所有線程都到達Barrier時執行

public void run() {

System.out.println("testCyclicBarrier run

");

array[2] = array[0] + array[1];

}

});

// 啟動線程

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

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

}

public static void main(String[] args) {

CyclicBarrierTest.testCyclicBarrier();

}

-- 學海無涯

Cyh的博客

導航

公告

常用鏈接

隨筆檔案(25)

文章分類(219)

文章檔案(220)

新聞檔案(66)

相冊

收藏夾(7)

最新隨筆

搜索

最新評論

閱讀排行榜

線程--CyclicBarrier