日期:2014-05-20  浏览次数:20727 次

关于CountDownLatch的一个问题
不知道为什么下面的代码没有执行循环,只执行了一次?请大侠帮忙解答,十分感谢


import java.util.concurrent.CountDownLatch;

class Driver{

public static void main(String[] args) {
CountDownLatch startSignal = new CountDownLatch(1);//启动信号
CountDownLatch doneSignal = new CountDownLatch(3);//记录3个工人的状态

try {
for(int i=0;i<3;i++){
System.out.println("************"+i);

//调用3个工人工作,虽然调用了start方法,但是worker的内部
//使用了CountDownLatch.await(),所以需要countDown(),才能工作
new Thread(new Worker(startSignal,doneSignal)).start();

System.out.println("经理即将发布任务");
startSignal.countDown();//让所有的工人开始工作

System.out.println("经理已发布任务,等待员工提交……");

doneSignal.await();//等待所有的工人都完成
System.out.println("所有工作完成");
}
}catch(Exception e){
e.printStackTrace();
}

}
}

class Worker implements Runnable{
CountDownLatch startSignal;
CountDownLatch doneSignal;
Worker(CountDownLatch startSignal,CountDownLatch doneSignal){
this.startSignal = startSignal;
this.doneSignal = doneSignal;
}

void doWork(){
System.out.println("线程" +Thread.currentThread().getName()+"已接收命令,开始执行!");
};

@Override
public void run() {
try {
System.out.println("线程"+Thread.currentThread().getName()+"已准备完毕");
startSignal.await();//工人处于就绪状态

doWork();
doneSignal.countDown();//每个工人做完自己的工作,就去提交
System.out.println("线程"+Thread.currentThread().getName()+"完成任务,已提交");
} catch (InterruptedException e) {
e.printStackTrace();
}
}

}

------解决方案--------------------
CountDownLatch不可重复使用,当计数器减少到0之后,就废了,无法继续使用了。
你在循环外创建CountDownLatch,在循环内使用,肯定是不行的,创建语句也应该写到循环内
------解决方案--------------------
引用:
这是另一个例子,可以得到正确结果,CountDownLatch是不可重用,不过跟是否在循环内部创建应该没有关系吧,只要保证它们是同一个CountDownLatch,就可以了,上面那个Driver的例子里,通过构造函数传递给Worker,应该都是同一个CountDownLatch,我也是根据API里的示例,照葫芦画瓢画出来的,自己实在看不出两个例子有什么区别,不都是通过Runable对象启动么,是不是就是通过构造函数传递CountDownLatch那里出了问题,还请能够做进一步解答,感激不尽

1楼说到对的,如果你在循环内await,会阻塞在第一次循环中,那种情况下,就把后面线程创建的机会给剥夺了

2楼程序可以,是因为程序中的for循环不是单线程执行的