Java多线程------让主线程等待所有子线程执行完毕

您的位置：
门户
>> 文章精选
>> 软件开发专栏
>> Java
>> 查看资讯

Java多线程------让主线程等待所有子线程执行完毕

发表于：2012-5-02 10:07

作者：未知来源：51Testing软件测试网采编

　　打印结果：

　　main开始
　　Thread-2开始...
　　Thread-1开始...
　　Thread-0开始...
　　Thread-3开始...
　　Thread-5开始...
　　Thread-4开始...
　　Thread-5结束. 还有5 个线程
　　Thread-1结束. 还有4 个线程
　　Thread-4结束. 还有3 个线程
　　Thread-2结束. 还有2 个线程
　　Thread-3结束. 还有1 个线程
　　Thread-0结束. 还有0 个线程
　　main结束.

　　更简单的方法：使用java.util.concurrent.CountDownLatch代替MyCountDown，用await()方法代替while(true){...}

　　ImportThread类

public 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() + " 个线程");
}
}

    public 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() + " 个线程");
    }
    }

　　主线程中

CountDownLatch threadSignal = new CountDownLatch(threadNum);//初始化countDown

for (int ii = 0; ii < threadNum; ii++) {//开threadNum个线程
final Iterator<String> itt = it.get(ii);
Thread t = new ImportThread(itt,sql,threadSignal);
t.start();
}
threadSignal.await();//等待所有子线程执行完
System.out.println(Thread.currentThread().getName() + "结束.");//打印结束标记

    CountDownLatch threadSignal = new CountDownLatch(threadNum);//初始化countDown
    for (int ii = 0; ii < threadNum; ii++) {//开threadNum个线程
    final Iterator<String> itt = it.get(ii);
    Thread t = new ImportThread(itt,sql,threadSignal);
    t.start();
    }
    threadSignal.await();//等待所有子线程执行完
    System.out.println(Thread.currentThread().getName() + "结束.");//打印结束标记

　　打印结果：

　　main开始
　　Thread-1开始...
　　Thread-0开始...
　　Thread-2开始...
　　Thread-3开始...
　　Thread-4开始...
　　Thread-5开始...
　　Thread-0结束. 还有5 个线程
　　Thread-1结束. 还有4 个线程
　　Thread-4结束. 还有3 个线程
　　Thread-2结束. 还有2 个线程
　　Thread-5结束. 还有1 个线程
　　Thread-3结束. 还有0 个线程
　　main结束.

44/4<1 2 34

精选软件测试好文，快来阅读吧~

搜索风云榜

测试技术了解

性能测试成长之路

挣点稿费

车载测试入门

文章资料精选