Java线程:新特点-障碍器[Java编程]
本文“Java线程:新特点-障碍器[Java编程]”是由七道奇为您精心收集,来源于网络转载,文章版权归文章作者所有,本站不对其观点以及内容做任何评价,请读者自行判断,以下是其具体内容:
障碍器是多线程并发掌握的一种手段,用法很简单.下面给个例子:
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
以上是“Java线程:新特点-障碍器[Java编程]”的内容,如果你对以上该文章内容感兴趣,你可以看看七道奇为您推荐以下文章:
本文地址: | 与您的QQ/BBS好友分享! |