java并发 CountDownLatch (五)
import java.util.concurrent.CountDownLatch;public class CountDownLatchTask implements Runnable {private CountDownLatch startCount;private CountDownLatch taskCount;public CountDownLatchTask(CountDownLatch startCount,CountDownLatch taskCount){this.startCount=startCount;this.taskCount=taskCount;}@Overridepublic void run() {try {//等待所有的线程任务初始化startCount.await();//模拟任务的代码Thread.sleep(1000);//任务完成后减少一次taskCount.countDown();} catch (InterruptedException e) {e.printStackTrace();}}}

?