java主线程控制子线程_CountDownLatch控制主线程等子线程执行完--Java多线程
1.[代码]CountDownLatch控制主线程等子线程执行完--Java多线程
package com.sihuatech.common;
import java.util.concurrent.CountDownLatch;
/**
* 执行线程
*
* @author lei 2011-7-28
*/
class ImportThread extends Thread {
private CountDownLatch threadsSignal;
public ImportThread(CountDownLatch threadsSignal) {
this.threadsSignal = threadsSignal;
}
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + "开始...");
// Do somethings
threadsSignal.countDown();// 线程结束时计数器减1
System.out.println(Thread.currentThread().getName() + "结束. 还有" + threadsSignal.getCount() + " 个线程");
}
}
/**
* 测试方法
*
* @author lei 2011-7-28
*/
public class Test {
public static void main(String[] args) {
int threadNum = 10;
CountDownLatch threadSignal = new CountDownLatch(threadNum);// 初始化countDown
for (int ii = 0; ii < threadNum; ii++) {// 开threadNum个线程
Thread t = new ImportThread(threadSignal);
t.start();
}
try {
threadSignal.await();// 等待所有子线程执行完
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + "结束.");
}
}