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

Java多线程-让主线程等待所有子线程执行完毕文章分类:Java编程 朋友让我帮忙写个程序从文本文档中导入数据到oracle数据库中,技术上没有什么难度,文档的格式都是固定的只要对应数据库中的字段解析就行了,关键在于性能。 数据量很大百万条记录,因此考虑到要用多线程并发执行,在写的过程中又遇到问题,我想统计所有子进程执行完毕总共的耗时,在第一个子进程创建前记录当前时间用System.currentTimeMillis()在最后一个子进程结束后记录当前时间,两次一减得到的时间差即为总共的用时,代码如下 Java代码 1. longtStart=System.currentTimeMillis(); 2. System.out.println(Thread.currentThread().getName()+开始);/打印开始标记 3. for(intii=0;iithreadNum;ii+)/开threadNum个线程 4. Runnabler=newRunnable() 5. Override6. publicvoidrun() 7. System.out.println(Thread.currentThread().getName()+开始); 8. /做一些事情. 9. System.out.println(Thread.currentThread().getName()+结束.); 10. 11. 12. Threadt=newThread(r); 13. t.start(); 14. 15. System.out.println(Thread.currentThread().getName()+结束.);/打印结束标记 16. longtEnd=System.currentTimeMillis(); 17. System.out.println(总共用时:+(tEnd-tStart)+millions); 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是否为空就知道还有没有子线程没有执行完了,类代码如下： Java代码 1. publicclassImportThreadextendsThread 2. privatestaticListrunningThreads=newArrayList(); 3. publicImportThread() 4. 5. Override6. publicvoidrun() 7. regist(this);/线程开始时注册 8. System.out.println(Thread.currentThread().getName()+开始.);/打印开始标记 9. /做一些事情. 10. unRegist(this);/线程结束时取消注册 11. System.out.println(Thread.currentThread().getName()+结束.);/打印结束标记 12. 13. publicvoidregist(Threadt) 14. synchronized(runningThreads) 15. runningThreads.add(t); 16. 17. 18. publicvoidunRegist(Threadt) 19. synchronized(runningThreads) 20. runningThreads.remove(t); 21. 22. 23. publicstaticbooleanhasThreadRunning() 24. return(runningThreads.size()0);/通过判断runningThreads是否为空就能知道是否还有线程未执行完 25. 26. public class ImportThread extends Thread private static List runningThreads = new ArrayList(); 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是否为空就能知道是否还有线程未执行完 主线程中代码： Java代码 1. longtStart=System.currentTimeMillis(); 2. System.out.println(Thread.currentThread().getName()+开始);/打印开始标记 3. for(intii=0;iithreadNum;ii+)/开threadNum个线程 4. Threadt=newImportThread(); 5. t.start(); 6. 7. while(true)/等待所有子线程执行完 8. if(!ImportThread.hasThreadRunning() 9. break; 10. 11. Thread.sleep(500); 12. 13. System.out.println(Thread.currentThread().getName()+结束.);/打印结束标记 14. longtEnd=System.currentTimeMillis(); 15. System.out.println(总共用时:+(tEnd-tStart)+millions); long tStart = System.currentTimeMillis(); System.out.println(Thread.currentThread().getName() + 开始);/打印开始标记 for (int ii = 0; ii 0); 11. 12. publicintgetCount() 13. returncount; 14. 15. publicvoidsetCount(intcount) 16. this.count=count; 17. 18. 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类 Java代码 1. publicclassImportThreadextendsThread 2. privateMyCountDownc; 3. publicImportThread(MyCountDownc) 4. this.c=c; 5. 6. Override7. publicvoidrun() 8. System.out.println(Thread.currentThread().getName()+开始.);/打印开始标记 9. /Dosomething 10. c.countDown();/计时器减1 11. System.out.println(Thread.currentThread().getName()+结束.还有+c.getCount()+个线程);/打印结束标记 12. 13. 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() + 个线程);/打印结束标记 主线程中 Java代码 1. System.out.println(Thread.currentThread().getName()+开始);/打印开始标记 2. MyCountDownc=newMyCountDown(threadNum);/初始化countDown 3. for(intii=0;iithreadNum;ii+)/开threadNum个线程 4. Threadt=newImportThread(c); 5. t.start(); 6. 7. while(true)/等待所有子线程执行完 8. if(!c.hasNext()break; 9. 10. System.out.println(Thread.currentThread().getName()+结束.);/打印结束标记 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类 Java代码 1. publicclassImportThreadextendsThread 2. privateCountDownLatchthreadsSignal; 3. publicImportThread(CountDownLatchthreadsSignal) 4. this.threadsSignal=threadsSignal; 5. 6. Override7. publicvoidrun() 8. System.out.println(Thread.currentThread().getName()+开始.); 9. /Dosomethings 10. threadsSignal.countDown();/线程结束时计数器减1 11. System.out.println(Thread.currentThread().getName()+结束.还有+threadsSignal.getCount()+个线程); 12. 13. 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() + 个线程); 主线程中 Java代码 1. CountDownLatchthreadSignal=newCountDownLatch(threadNum);/初始化countDown 2. for(intii=0;iithreadNum;ii+)/开threadNum