- 浏览: 239244 次
- 性别:
- 来自: 上海
文章分类
最新评论
-
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 1075版权声明:转载时请以超链接形式标明文章原始出处和作者信息及本声 ... -
Caused by: org.codehaus.jackson.map.JsonMappingException
2011-08-29 16:09 12327写道 No serializer found for cla ... -
JVM监控工具介绍jstack, jconsole, jinfo, jmap, jdb, jstat(2)
2011-08-10 13:44 3798如果能熟练运用这些命令,尤其是在linux下,那么完全可以代替 ... -
JVM监控工具介绍jstack, jconsole, jinfo, jmap, jdb, jstat (1)
2011-08-10 13:44 1137jstack -- 如果java程序崩溃生成core文 ... -
IT公司中最流行的10种编程语言
2011-08-05 13:12 9411. C语言 C语言是一种 ... -
JDK自带线程池总类介绍介绍
2011-07-28 20:38 6921、newFixedThreadPool创建一个指定工作线程数 ... -
深入浅出多线程(4)对CachedThreadPool OutOfMemoryError问题的一些想法
2011-07-28 20:37 1488线程池是Conncurrent包提供给我们的一个重要的礼物。 ... -
Quartz管理类
2011-07-18 17:11 1159package com.sihuatech.project.t ... -
JAVA写文件到FTP的几种方法
2011-07-18 11:32 25891.使用URL: URL url = n ... -
为什么会出现 java.util.ConcurrentModificationException 异常?
2011-07-15 14:47 1455工作中碰到个ConcurrentModificationExc ... -
装饰模式
2011-07-12 11:41 12051) 装饰模式 装饰模式 (Decor ... -
全面解析Java中的String对象的数据类型
2011-07-11 12:56 9661. 首先String不属于8种基本数据类型,String是一 ... -
oscache配置详解
2011-07-08 14:36 2067#一、内存缓存或硬盘、数据库缓存 cache.memory= ... -
oscache使用指南
2011-07-07 15:19 2427一、简介 Cache是一种用于提高系统响应速度、改善 ... -
java文件操作
2011-07-05 12:10 699package Test; import ja ... -
map的三种遍历方法!
2011-07-04 13:27 920集合的一个很重要的操作---遍历,学习了三种遍历方法,三种 ... -
Java中String类型的参数传递问题的解析
2011-06-29 18:31 1146publicclass StringAsParamOfMeth ... -
not in 优化
2011-06-20 14:35 145501.select * from emp where emp_ ... -
简单工厂模式与策略模式的区别
2011-06-14 16:10 3245工厂(Factory)模式我们可以做如下理解,假设有一个A ... -
UML中的关系
2011-05-30 17:14 878uml定义的关系主要有六种:依赖、类属、关联、实现、聚合和组合 ...
相关推荐
Java多线程--等待所有子线程执行完的五种方法 Java多线程--等待所有子线程执行完的五种方法 Java多线程--等待所有子线程执行完的五种方法 Java多线程--等待所有子线程执行完的五种方法 Java多线程--等待所有子线程...
Java主线程等待所有子线程执行完毕在执行,其实在我们的工作中经常的用到,本篇文章就介绍了Java多线程--让主线程等待所有子线程执行完毕在执行,有需要的可以了解一下。
数据量很大百万条记录,因此考虑到要用多线程并发执行,在写的过程中又遇到问题,我想统计所有子进程执行完毕总共的耗时,在第一个子进程创建前记录当前时间用System.currentTimeMillis()在后一个子进程结束后...
java 子线程通过观察者模式通知主线程
子线程更新主线程数据(再谈多线程)
Unity除了一些基本的数据类型,几乎所有的API都不能在子线程中调用,如果项目中有一段很耗时操作,unity可能会出现“卡死...因此针对这个问题再加上查找了一些资料,弄出了一个小工具,可以子线程与主线程的相互访问。
C# Winfrom必须掌握的技术,主线程显示数据,子线程获取数据,这是我做项目实际用到的技术。
非常实用不解释,用了才知道 个人收藏的一部分资料将陆续给大家上传
子线程任务发生异常,主线程事务如何回滚
我就废话不多说了,还是直接看代码吧! from time import ctime import threading import time def a(): #for i in range(5): print('Program a is running... at ', ctime(),u'.线程名为:',threading.current...
自己学着编写的一个JAVA多线程程序,该程序实现的功能是:在主线程main中创建两个子线程,A和B,线程A先运行,再运行B线程,当两个子线程都运行完毕后,才运行主线程,并最终结束整个程序的运行。 希望该程序对初学...
下面小编就为大家带来一篇C#子线程执行完后通知主线程的方法。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
Handler消息传递详解,子线程到子线程,主线程到子线程,子线程到主线程 三种消息,Looper,Handler工作机制详解 https://blog.csdn.net/shoneworn/article/details/80447651
下面小编就为大家分享一篇Java父线程(或是主线程)等待所有子线程退出的实例,具有很好的参考价值,希望对大家有所帮助
C#子线程刷新主线程示例源码 功能介绍: 使用线程操作 1、实时显示当前时间 2、输入加数和被加数,自动出现结果 技术特点: 使用了多线程实现了子线程刷新主线程 ,使用委托刷新主线程。 注意: 开发环境为...
主线程如何捕获子线程的异常---马克-to-win java视频的介绍
c#子线程如何读取及设置主线程ui的值,自己录的一个小视频,方便理解,比较菜鸟的方法,请勿喷!
C++ thread退出线程 多线程 子线程控制退出主线程 window VS2017 Debug Error! Abort() has been called. C++ thread退出线程 多线程 子线程控制退出主线程 window VS2017 Debug Error! Abort() has been called.
AutoJs源码-子线程与主线程逻辑。本资源购买前提醒:本源码都是实际autojs项目模板,安装好autojs直接运行即可打开。1、支持低版本autojs。2、资源仅供学习与参考,请勿用于商业用途,否则产生的一切后果将由您自己...