Java线程：新特征-障碍器

核心提示：障碍器是多线程并发控制的一种手段，用法很简单，Java线程：新特征-障碍器，下面给个例子：importjava.util.concurrent.BrokenBarrierException;importjava.util.concurrent.CyclicBarrier;/***Java线程：新特征-障碍器**@aut

障碍器是多线程并发控制的一种手段，用法很简单。下面给个例子：

import　java.util.concurrent.BrokenBarrierException;
import　java.util.concurrent.CyclicBarrier;
/**
*　Java线程：新特征-障碍器
*
*　@author　leizhimin　
*/
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

从执行结果可以看出，所有子任务完成的时候，主任务执行了，达到了控制的目标。

出处：http://lavasoft.blog.51cto.com/62575/222738