欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

主线程等待所有子线程执行完成

程序员文章站 2022-04-17 18:33:14
...
使用CountDownLatch使主线程等待所有子线程执行完,再继续执行。

public static void main(String[] args) throws InterruptedException {
t1();
t2();
}

private static long getTime() {
return System.currentTimeMillis();
}

public static void t3() {
long dd1 = System.currentTimeMillis();
while (getTime() - dd1 <= 10000) {

}
}

public static void t2() throws InterruptedException {
long d1 = System.currentTimeMillis();
int threadNumber = 10;
final CountDownLatch countDownLatch = new CountDownLatch(threadNumber);
for (int i = 0; i < threadNumber; i++) {
final int threadID = i;
new Thread() {
public void run() {
System.out.println("start" + threadID);
t3();
System.out.println("end" + threadID);
System.out.println(String.format(
"threadID:[%s] finished!!", threadID));
countDownLatch.countDown();
}
}.start();
}
countDownLatch.await();
System.out.println("main thread finished!!");
long d2 = System.currentTimeMillis();
System.out.println("time2:" + (d2 - d1));
}

public static void t1() throws InterruptedException {
long d1 = System.currentTimeMillis();
int threadNumber = 10;
for (int i = 0; i < threadNumber; i++) {
final int threadID = i;
Thread thread = new Thread() {
public void run() {
System.out.println("start" + threadID);
t3();
System.out.println("end" + threadID);
System.out.println(String.format(
"threadID:[%s] finished!!", threadID));
}
};
thread.start();
thread.join();
}
System.out.println("main thread finished!!");
long d2 = System.currentTimeMillis();
System.out.println("time1:" + (d2 - d1));
}


[url=http://www.osight.com]云游四方[/url]
相关标签: thread