- 浏览: 243070 次
- 性别:
- 来自: 上海
文章分类
最新评论
-
di1984HIT:
学习了。
CMS项目中用到的技术(全) -
di1984HIT:
就是用xml麻烦~
RESTEasy入门 -
di1984HIT:
学习了~~
RESTEasy入门 -
真三武侯:
写得很好,感谢分享经验心得!
RESTEasy入门 -
fangcensi:
是不是还有一个application文件,没写出来
RESTEasy入门
数据量很大百万条记录,因此考虑到要用多线程并发执行,在写的过程中又遇到问题,我想统计所有子进程执行完毕总共的耗时,在第一个子进程创建前记录当前时间用System.currentTimeMillis()在最后一个子进程结束后记录当前时间,两次一减得到的时间差即为总共的用时,代码如下 Java代码 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"); 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代码 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是否为空就能知道是否还有线程未执行完 } } 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是否为空就能知道是否还有线程未执行完 } } 主线程中代码: Java代码 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"); 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类 Java代码 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; } } 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代码 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() + " 个线程");//打印结束标记 } } 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代码 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() + "结束.");//打印结束标记 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代码 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() + " 个线程"); } } 主线程中 Java代码 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结束.
发表评论
-
Java基本功——Reference
2011-10-08 17:52 1128版权声明:转载时请以超链接形式标明文章原始出处和作者信息及本声 ... -
Caused by: org.codehaus.jackson.map.JsonMappingException
2011-08-29 16:09 12370写道 No serializer found for cla ... -
JVM监控工具介绍jstack, jconsole, jinfo, jmap, jdb, jstat(2)
2011-08-10 13:44 3868如果能熟练运用这些命令,尤其是在linux下,那么完全可以代替 ... -
JVM监控工具介绍jstack, jconsole, jinfo, jmap, jdb, jstat (1)
2011-08-10 13:44 1188jstack -- 如果java程序崩溃生成core文 ... -
IT公司中最流行的10种编程语言
2011-08-05 13:12 9921. C语言 C语言是一种 ... -
JDK自带线程池总类介绍介绍
2011-07-28 20:38 7481、newFixedThreadPool创建一个指定工作线程数 ... -
深入浅出多线程(4)对CachedThreadPool OutOfMemoryError问题的一些想法
2011-07-28 20:37 1554线程池是Conncurrent包提供给我们的一个重要的礼物。 ... -
Quartz管理类
2011-07-18 17:11 1216package com.sihuatech.project.t ... -
JAVA写文件到FTP的几种方法
2011-07-18 11:32 26511.使用URL: URL url = n ... -
为什么会出现 java.util.ConcurrentModificationException 异常?
2011-07-15 14:47 1500工作中碰到个ConcurrentModificationExc ... -
装饰模式
2011-07-12 11:41 12491) 装饰模式 装饰模式 (Decor ... -
全面解析Java中的String对象的数据类型
2011-07-11 12:56 10241. 首先String不属于8种基本数据类型,String是一 ... -
oscache配置详解
2011-07-08 14:36 2134#一、内存缓存或硬盘、数据库缓存 cache.memory= ... -
oscache使用指南
2011-07-07 15:19 2480一、简介 Cache是一种用于提高系统响应速度、改善 ... -
java文件操作
2011-07-05 12:10 744package Test; import ja ... -
map的三种遍历方法!
2011-07-04 13:27 986集合的一个很重要的操作---遍历,学习了三种遍历方法,三种 ... -
Java中String类型的参数传递问题的解析
2011-06-29 18:31 1207publicclass StringAsParamOfMeth ... -
not in 优化
2011-06-20 14:35 150801.select * from emp where emp_ ... -
简单工厂模式与策略模式的区别
2011-06-14 16:10 3319工厂(Factory)模式我们可以做如下理解,假设有一个A ... -
UML中的关系
2011-05-30 17:14 925uml定义的关系主要有六种:依赖、类属、关联、实现、聚合和组合 ...
相关推荐
在Java多线程编程中,有时我们需要确保所有子线程执行完毕后再进行后续操作,例如在并发测试、数据聚合或资源清理等场景。本篇文章将详细介绍五种在Java中等待所有子线程执行完的方法。 ### 方法一:使用`sleep`...
在Java多线程编程中,有时我们需要确保主线程在所有子线程完成执行后再继续执行。这在处理大量并发任务,比如数据导入、并行计算等场景中是常见的需求。以下是如何实现这一功能的详细解释。 首先,让我们理解为什么...
Java 主线程等待子线程执行完毕 Java 中的多线程编程是非常重要的一部分,特别是在需要并发执行多个任务的情况下。然而,在某些情况下,我们需要等待所有子线程执行完毕后再继续执行主线程的剩余动作。这时,我们...
要解决“让主线程等待所有子线程执行完毕”的问题,可以采用以下策略: 1. 使用`join()`方法:如提到的,直接在每个子线程的`start()`之后调用`t.join()`,会导致所有线程按顺序执行。这是因为`join()`会让主线程...
总的来说,Java提供了丰富的多线程同步机制,可以根据实际需求选择合适的方法来实现“主线程等待所有子线程完成再继续”的功能。在并发编程中,理解并灵活运用这些工具对于提高程序效率和避免死锁等问题至关重要。
在多线程编程中,有时我们需要确保主线程在所有子线程执行完毕后才继续执行。这通常是为了保证数据的一致性或者按照特定顺序完成任务。"主线程等待子多线程(无结果返回)执行完成再继续执行"这个主题就涉及到如何在...
本篇文章将深入探讨如何在Python中实现多线程,并让主线程等待所有子线程结束。 首先,我们需要了解Python中的`threading`模块,它是Python标准库中用于处理多线程的模块。在示例代码中,我们创建了两个函数`a()`和...
自己学着编写的一个JAVA多线程程序,该程序实现的功能是:在主线程main中创建两个子线程,A和B,线程A先运行,再运行B线程,当两个子线程都运行完毕后,才运行主线程,并最终结束整个程序的运行。 希望该程序对初学...
为解决这个问题,我们需要使用同步机制,如Java中的`join()`方法或C#的`Thread.Join()`,让主线程等待所有子线程完成后再继续执行。当调用`join()`方法时,主线程会被阻塞,直到被调用的线程执行完毕。 例如,在...
// 主线程等待thread1执行完毕 thread1.join(); ``` **异常处理**: 在多线程环境中,每个线程都有自己的异常处理机制。主线程不会捕获子线程抛出的异常,因此在子线程中需要妥善处理异常,避免程序意外终止。 总...
1. **主线程等待子线程完成**:在多线程环境中,主线程有时需要等待所有子线程执行完毕后才进行后续处理,如清理资源或汇总子线程的计算结果。 2. **线程间数据同步**:当一个线程依赖于另一个线程产生的数据时,...
然后调用`s.join()`,这就意味着主线程会暂停执行,直到子线程`s`执行完毕。这种行为确保了子线程的操作先于主线程的后续操作完成。 在`join()`方法的源码分析中,我们可以看到两个重载版本:一个不带参数,一个带...
线程是程序执行流的最小单元,一个标准的程序只能执行一个任务,而使用多线程技术可以让程序同时执行多个任务,从而提高程序的性能。 #### 2. 线程与进程的区别 - **进程**:每个进程都有独立的代码和数据空间(即...
当主线程结束时,所有由主线程创建的子线程也将随之结束。这是Java虚拟机(JVM)的行为,确保了程序的整洁关闭。 #### 4. 线程的终止 除了自然结束外,线程还可以通过调用`stop()`方法强制停止。然而,此方法已被...
2. **主线程等待子线程**:接着,主线程通过调用`join()`方法等待子线程执行完毕。 3. **子线程执行完毕**:子线程执行完毕后,主线程继续执行后续逻辑。 通过这种方式,我们可以清晰地控制线程之间的执行顺序。 ...
在Java多线程编程中,CountDownLatch是一个非常重要的同步工具类,它可以帮助我们协调多个线程之间的交互。本文将深入探讨CountDownLatch的工作原理、使用场景以及相关源码分析。 CountDownLatch是一个计数器,初始...
8. 调用`countDownLatch.await()`,主线程会阻塞等待直到所有子线程执行完毕。 需要注意的是,为了确保线程安全,文件读取和重命名操作应当采取措施避免冲突,例如可以在读取文件时使用文件锁机制,或是在重命名...
每个Java应用程序至少有一个线程,称为主线程,它是程序执行的起点。线程的创建通常是通过实现`Runnable`接口或者继承`Thread`类来完成的。一旦创建了线程,可以通过调用`start()`方法启动它,这将使得线程进入就绪...