脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Java让主线程等待所有子线程执行完毕

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

 更新时间：2016年11月09日 08:59:35   作者：yadsun  
Java主线程等待所有子线程执行完毕在执行，其实在我们的工作中经常的用到，本篇文章就介绍了Java多线程--让主线程等待所有子线程执行完毕在执行，有需要的可以了解一下。

朋友让我帮忙写个程序从文本文档中导入数据到oracle数据库中,技术上没有什么难度,文档的格式都是固定的只要对应数据库中的字段解析就行了,关键在于性能。

数据量很大百万条记录,因此考虑到要用多线程并发执行,在写的过程中又遇到问题,我想统计所有子进程执行完毕总共的耗时,在第一个子进程创建前记录当前时间用System.currentTimeMillis()在最后一个子进程结束后记录当前时间,两次一减得到的时间差即为总共的用时,代码如下 

long tStart = System.currentTimeMillis(); 
System.out.println(Thread.currentThread().getName() + "开始");//打印开始标记 
for (int ii = 0; ii < threadNum; ii++) {//开threadNum个线程 
Runnable r = new Runnable(){ 
@Override 
public void run(){ 
System.out.println(Thread.currentThread().getName() + "开始"); 
//做一些事情... ... 
System.out.println(Thread.currentThread().getName() + "结束."); 
} 
} 
Thread t = new Thread(r); 
t.start(); 
} 
System.out.println(Thread.currentThread().getName() + "结束.");//打印结束标记 
long tEnd = System.currentTimeMillis(); 
System.out.println("总共用时:"+ (tEnd - tStart) + "millions");

结果是几乎在for循环结束的瞬间就执行了主线程打印总共用时的语句,原因是所有的子线程是并发执行的,它们运行时主线程也在运行,这就引出了一个问题即本文标题如何"让主线程等待所有子线程执行完毕"。试过在每个子线程开始后加上t.join(),结果是所有线程都顺序执行,这就失去了并发的意义了,显然不是我想要的。 

网上Google了很久也没有找到解决方案,难道就没有人遇到过这种需求吗?还是这个问题太简单了?无耐只得自己想办法了... 

最后我的解决办法是,自定义一个ImportThread类继承自java.lang.Thread,重载run()方法,用一个List属性保存所有产生的线程,这样只要判断这个List是否为空就知道还有没有子线程没有执行完了,类代码如下： 

public class ImportThread extends Thread { 
private static List<Thread> runningThreads = new ArrayList<Thread>(); 
public ImportThread() { 
} 
@Override 
public void run() { 
regist(this);//线程开始时注册 
System.out.println(Thread.currentThread().getName() + "开始...");//打印开始标记 
//做一些事情... ... 
unRegist(this);//线程结束时取消注册 
System.out.println(Thread.currentThread().getName() + "结束.");//打印结束标记 
} 
public void regist(Thread t){ 
  synchronized(runningThreads){  
    runningThreads.add(t); 
  } 
} 
public void unRegist(Thread t){ 
  synchronized(runningThreads){  
    runningThreads.remove(t); 
  } 
} 
public static boolean hasThreadRunning() { 
return (runningThreads.size() > 0);//通过判断runningThreads是否为空就能知道是否还有线程未执行完 
} 
}

主线程中代码： 

long tStart = System.currentTimeMillis(); 
System.out.println(Thread.currentThread().getName() + "开始");//打印开始标记 
for (int ii = 0; ii < threadNum; ii++) {//开threadNum个线程 
Thread t = new ImportThread(); 
t.start(); 
} 
while(true){//等待所有子线程执行完 
if(!ImportThread.hasThreadRunning()){ 
break; 
} 
Thread.sleep(500); 
} 
System.out.println(Thread.currentThread().getName() + "结束.");//打印结束标记 
long tEnd = System.currentTimeMillis(); 
System.out.println("总共用时:"+ (tEnd - tStart) + "millions");

打印的结果是： 

main开始 
Thread-1开始... 
Thread-5开始... 
Thread-0开始... 
Thread-2开始... 
Thread-3开始... 
Thread-4开始... 
Thread-5结束. 
Thread-4结束. 
Thread-2结束. 
Thread-0结束. 
Thread-3结束. 
Thread-1结束. 
main结束.          

总共用时:20860millions 

可以看到main线程是等所有子线程全部执行完后才开始执行的。 

================================================================================================= 

上面的方法有一个隐患:如果线程1开始并且结束了,而其他线程还没有开始此时runningThreads的size也为0,主线程会以为所有线程都执行完了。解决办法是用一个非简单类型的计数器来取代List型的runningThreads,并且在线程创建之前就应该设定好计数器的值。 

MyCountDown类 
 

  public class MyCountDown { 
private int count; 
public MyCountDown(int count){ 
this.count = count; 
} 
public synchronized void countDown(){ 
count--; 
} 
public synchronized boolean hasNext(){ 
return (count > 0); 
} 
public int getCount() { 
return count; 
} 
public void setCount(int count) { 
this.count = count; 
} 
}

ImportThread类 

 public class ImportThread extends Thread { 
private MyCountDown c; 
public ImportThread(MyCountDown c) { 
this.c = c; 
} 
@Override 
public void run() { 
System.out.println(Thread.currentThread().getName() + "开始...");//打印开始标记 
//Do something 
c.countDown();//计时器减1 
System.out.println(Thread.currentThread().getName() + "结束. 还有" + c.getCount() + " 个线程");//打印结束标记 
} 
}

主线程中 

System.out.println(Thread.currentThread().getName() + "开始");//打印开始标记 
MyCountDown c = new MyCountDown(threadNum);//初始化countDown 
for (int ii = 0; ii < threadNum; ii++) {//开threadNum个线程 
Thread t = new ImportThread(c); 
t.start(); 
} 
while(true){//等待所有子线程执行完 
if(!c.hasNext()) break; 
} 
System.out.println(Thread.currentThread().getName() + "结束.");//打印结束标记

打印结果: 

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

主线程中 

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结束.

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

相关文章

  • 一篇文章带你了解java Object根类中关于toString,equals的方法

    一篇文章带你了解java Object根类中关于toString,equals的方法

    这篇文章主要介绍了Object类toString()和equals()方法使用解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2021-09-09
  • Java复合语句的使用方法详解

    Java复合语句的使用方法详解

    这篇文章主要介绍了Java编程中复合语句，结合相关的具体实例介绍了其用法,需要的朋友可以参考下
    2017-09-09
  • java 中HashMap、HashSet、TreeMap、TreeSet判断元素相同的几种方法比较

    java 中HashMap、HashSet、TreeMap、TreeSet判断元素相同的几种方法比较

    这篇文章主要介绍了从源码的角度浅析HashMap、TreeMap元素的存储和获取元素的逻辑；从Map与Set之间的关系浅析常用的Set中元素的存储和判断是否重复的逻辑,需要的朋友可以参考下
    2017-01-01
  • MyBatisCodeHelperPro最新激活方法(有效方法)

    MyBatisCodeHelperPro最新激活方法(有效方法)

    这篇文章主要介绍了MyBatisCodeHelperPro最新激活方法亲测有效，非常好用，小编今天以idea2021.2.1为例给大家详细讲解,需要的朋友可以参考下
    2022-08-08
  • Spring bean生命周期配置过程解析

    Spring bean生命周期配置过程解析

    这篇文章主要介绍了Spring bean生命周期配置过程解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-03-03
  • spring boot基于DRUID实现数据源监控过程解析

    spring boot基于DRUID实现数据源监控过程解析

    这篇文章主要介绍了spring boot基于DRUID实现数据源监控过程解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-12-12
  • 使用Java SDK实现离线签名

    使用Java SDK实现离线签名

    这篇文章主要介绍了使用Java SDK实现离线签名，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2019-03-03
  • 简单了解JAVA NIO

    简单了解JAVA NIO

    这篇文章主要介绍了JAVA NIO的的相关资料，文中讲解非常细致，帮助大家更好的理解和学习，感兴趣的朋友可以了解下
    2020-07-07
  • 面向对象编程:Java中的抽象数据类型

    面向对象编程:Java中的抽象数据类型

    面向对象编程:Java中的抽象数据类型...
    2006-12-12
  • SpringBoot配置Apollo代码实例

    SpringBoot配置Apollo代码实例

    这篇文章主要介绍了SpringBoot配置Apollo代码实例,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2019-10-10

最新评论