java中CyclicBarrier簡(jiǎn)單入門使用
來(lái)源：程序員人生 發(fā)布時(shí)間：2014-11-06 08:39:22 閱讀次數(shù)：3151次
1個(gè)同步輔助類，它允許1組線程相互等待，直到到達(dá)某個(gè)公共屏障點(diǎn) (common barrier point)。在觸及1組固定大小的線程的程序中，這些線程必須不時(shí)地相互等待，此時(shí) CyclicBarrier 很有用。由于該 barrier 在釋放等待線程后可以重用，所以稱它為循環(huán) 的 barrier。
CyclicBarrier 支持1個(gè)可選的
Runnable 命令，在1組線程中的最后1個(gè)線程到達(dá)以后（但在釋放所有線程之前），該命令只在每一個(gè)屏障點(diǎn)運(yùn)行1次。若在繼續(xù)所有參與線程之前更新同享狀態(tài)，此屏障操作 很有用。 在java JDK中是這樣解釋的，在我們平常開發(fā)中常常需要1組線程結(jié)束以后，再接著進(jìn)行，我們就需要斟酌使用這個(gè)類了。
履行以后打印以下結(jié)果：
線程 pool⑴-thread⑴行將到達(dá)線程集合點(diǎn)1，已有 1 到達(dá)繼續(xù)等候
線程 pool⑴-thread⑶行將到達(dá)線程集合點(diǎn)1，已有 2 到達(dá)繼續(xù)等候
線程 pool⑴-thread⑵行將到達(dá)線程集合點(diǎn)1，已有 3 到達(dá)都到齊，走吧
線程 pool⑴-thread⑵行將到達(dá)線程集合點(diǎn)2，已有 1 到達(dá)繼續(xù)等候
線程 pool⑴-thread⑴行將到達(dá)線程集合點(diǎn)2，已有 2 到達(dá)繼續(xù)等候
線程 pool⑴-thread⑶行將到達(dá)線程集合點(diǎn)2，已有 3 到達(dá)都到齊，走吧
線程 pool⑴-thread⑶行將到達(dá)線程集合點(diǎn)3，已有 1 到達(dá)繼續(xù)等候
線程 pool⑴-thread⑴行將到達(dá)線程集合點(diǎn)3，已有 2 到達(dá)繼續(xù)等候
線程 pool⑴-thread⑵行將到達(dá)線程集合點(diǎn)3，已有 3 到達(dá)都到齊，走吧
<pre name="code" class="java">import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class CyclicBarrierTest {
/**
* @param args
*/
public static void main(String[] args) {
ExecutorService ThreadPool = Executors.newCachedThreadPool();
final CyclicBarrier cyclic = new CyclicBarrier(3);
for(int i=0;i<3;i++){
Runnable runnable = new Runnable() {
@Override
public void run() {
try {
Thread.sleep((long) (Math.random()*3000));
System.out.println("線程 " + Thread.currentThread().getName() + "行將到達(dá)線程集合點(diǎn)1，已有 " + (cyclic.getNumberWaiting()+1) + " 到達(dá)" + (cyclic.getNumberWaiting()==2 ? "都到齊，走吧": "繼續(xù)等候"));
cyclic.await();
Thread.sleep((long) (Math.random()*3000));
System.out.println("線程 " + Thread.currentThread().getName() + "行將到達(dá)線程集合點(diǎn)2，已有 " + (cyclic.getNumberWaiting()+1) + " 到達(dá)" + (cyclic.getNumberWaiting()==2 ? "都到齊，走吧": "繼續(xù)等候"));
cyclic.await();
Thread.sleep((long) (Math.random()*3000));
System.out.println("線程 " + Thread.currentThread().getName() + "行將到達(dá)線程集合點(diǎn)3，已有 " + (cyclic.getNumberWaiting()+1) + " 到達(dá)" + (cyclic.getNumberWaiting()==2 ? "都到齊，走吧": "繼續(xù)等候"));
cyclic.await();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
}
};
ThreadPool.execute(runnable);
}
}
}
生活不易，碼農(nóng)辛苦
如果您覺(jué)得本網(wǎng)站對(duì)您的學(xué)習(xí)有所幫助,可以手機(jī)掃描二維碼進(jìn)行捐贈(zèng)
