关于CountDownLatch的一个有关问题

关于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&lt;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循环不是单线程执行的

关于CountDownLatch的一个有关问题

热点推荐