统计所有子进程执行完毕总共的耗时,在第一个子进程创建前记录当前时间用System.currentTimeMillis()在最后一个子进程结束后记
录当前时间,两次一减得到的时间差即为总共的用时,代码如下
-
long
tStart = System.currentTimeMillis();
-
System.out.println(Thread.currentThread().getName() + "开始"
);
-
for
(
int
ii =
0
; ii < threadNum; ii++) {
-
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是否为空就知道还有没有子线程
没有执行完了,类代码如下：
-
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
);
-
}
-
}
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++) {
-
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类
-
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类
-
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() + "开始..."
);
-
-
c.countDown();
-
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() + " 个线程");//打印结束标记
}
}
主线程中
-
System.out.println(Thread.currentThread().getName() +
"开始"
);
-
MyCountDown c = new
MyCountDown(threadNum);
-
for
(
int
ii =
0
; ii < threadNum; ii++) {
-
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类
-
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() + "开始..."
);
-
-
threadsSignal.countDown();
-
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);
-
for
(
int
ii =
0
; ii < threadNum; ii++) {
-
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结束.
see：http://3ccoder.iteye.com/blog/581476
分享到：
相关推荐
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、资源仅供学习与参考，请勿用于商业用途，否则产生的一切后果将由您自己...