Java并发编程示例(六)：等待线程执行终止
在某些场景下，我们必须等待线程执行完成才能进行下一步工作。例如，某些程序在开始执行之前，需要先初始化一些资源。这时，我们可以启动一个线程专门来做初始化任务，等到线程任务完成后，再去执行其他部分。
为此，Thread类为我们提供了join()方法。当我们使用线程对象调用此方法时，正在掉调用的线程对象将被推迟到被调用对象执行完成后再开始执行。
在本节，示例程序演示等待初始化方法完成后，再去执行其他任务。
知其然
按照下面所示步骤，完成示例程序。
1.创建一个名为DataSourcesLoader的类，并且实现Runnable接口。代码如下：
public class DataSourcesLoader implements Runnable {
2.实现run()方法，向控制台打印出一条信息以说明开始执行，然后睡眠4秒钟，再向控制台打印一条信息来说明线程执行结束。代码如下：
@Override
public void run() {
System.out.printf("Beginning data sources loading: %s\n",
new Date());
try {
TimeUnit.SECONDS.sleep(4);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.printf("Data sources loading has finished: %s\n",
new Date());
}
3.创建一个名为NetworkConnectionsLoader的类，并且实现Runnable接口。 实现run()方法，该方法代码与DataSourcesLoader类的run()方法一样，只是这个睡眠6秒钟。
4.实现示例的主类，并且实现main()方法。代码如下：
public class Main {
public static void main(String[] args) {
5.创建一个DataSourcesLoader对象，以及一个启动它执行的Thread对象。代码如下：
DataSourcesLoader dsLoader = new DataSourcesLoader();
Thread thread1 = new Thread(dsLoader, "DataSourcesLoader");
6.创建一个NetworkConnectionsLoader对象，以及一个启动它执行的Thread对象。代码如下：
NetworkConnectionsLoader ncLoader = new NetworkConnectionsLoader();
Thread thread2 = new Thread(ncLoader, "NetworkConnectionsLoader");
7.调用两个Thread对象的start()方法。代码如下：
thread1.start();
thread2.start();
8.调用join()方法，来等待两个线程完成其任务。这个方法会抛出InterruptedException异常，所以要捕获该异常。代码如下：
try {
thread1.join();
thread2.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
9.向控制台打印一句话，表明程序执行结束。代码如下：
System.out.printf("Main: Configuration has been loaded: %s\n",
new Date());
10.运行程序，查看执行效果。
知其所以然
当运行这个示例程序时，我们可以看到两个线程启动了它们的执行。首先，是DataSourcesLoader完成了它的执行；然后，是NetworkConnectionsLoader完成了它的执行。这时，主线程继续它的执行，然后向控制台打印出终止信息。
永无止境
Java提供了另外两种重载的join()方法：
join(long milliseconds)
join(long milliseconds, long nanos)
第一种方式，不会直到被调用完成任务，而是等待参数指定的时间后就开始执行；例如，如果thread1调用该方法，thread1.join(1000)，当thread1线程满足如下其中之一的条件就会继续执行：
1.thread2完成它的执行；
2.1000毫秒过后；
当这两个条件中的其中之一为真时，join()方法就会返回，开始继续执行原来的任务。
第二种方式的方法和第一种很类似，只是多了一个纳秒级的时间参数。
拿来主义
本文是从 《Java 7 Concurrency Cookbook》 （D瓜哥窃译为 《Java7并发示例集》 ）翻译而来，仅作为学习资料使用。没有授权，不得用于任何商业行为。
小有所成
本节所用示例代码的完整版。
DataSourcesLoader类的完整代码
package com.diguage.books.concurrencycookbook.chapter1.recipe6;
import java.util.Date;
import java.util.concurrent.TimeUnit;
/**
* Date: 2013-09-19
* Time: 09:15
*/
public class DataSourcesLoader implements Runnable {
@Override
public void run() {
System.out.printf("Beginning data sources loading: %s\n",
new Date());
try {
TimeUnit.SECONDS.sleep(4);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.printf("Data sources loading has finished: %s\n",
new Date());
}
}
NetworkConnectionsLoader类的完整代码
package com.diguage.books.concurrencycookbook.chapter1.recipe6;
import java.util.Date;
import java.util.concurrent.TimeUnit;
/**
* Date: 2013-09-19
* Time: 09:21
*/
public class NetworkConnectionsLoader implements Runnable {
@Override
public void run() {
System.out.printf("Beginning data sources loading: %s\n",
new Date());
try {
TimeUnit.SECONDS.sleep(6);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.printf("Data sources loading has finished: %s\n",
new Date());
}
}
Main类的完整代码
package com.diguage.books.concurrencycookbook.chapter1.recipe6;
import java.util.Date;
/**
* Date: 2013-09-19
* Time: 09:25
*/
public class Main {
public static void main(String[] args) {
DataSourcesLoader dsLoader = new DataSourcesLoader();
Thread thread1 = new Thread(dsLoader, "DataSourcesLoader");
NetworkConnectionsLoader ncLoader = new NetworkConnectionsLoader();
Thread thread2 = new Thread(ncLoader, "NetworkConnectionsLoader");
thread1.start();
thread2.start();
try {
thread1.join();
thread2.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.printf("Main: Configuration has been loaded: %s\n",
new Date());
}
}
相关文章
下面小编就为大家分享一篇基于Intellij Idea乱码的解决方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2018-03-03
这篇文章主要介绍了Java之BigDecimal实现详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2021-01-01
今天带大家了解SpringBoot的相关知识,文中对SpringBoot的配置原理作了非常详细的图文示例及介绍,需要的朋友可以参考下2021-06-06
这篇文章主要介绍了Spring Boot打包部署和环境配置详解，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2019-05-05
这篇文章主要为大家详细介绍了Myeclipse 2016下Aptana安装教程，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-05-05
这篇文章主要为大家详细介绍了23种设计模式之java工厂模式，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2017-11-11
这篇文章主要介绍了解决java 命令行乱码的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2021-02-02
这篇文章主要为大家详细介绍了java实现简单猜拳小游戏，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-11-11
目前系统中有很多需要用到延时处理的功能，本文就为大家介绍了Java实现异步延迟队列的方法，文中的示例代码讲解详细，需要的可以参考一下2023-03-03
这篇文章主要介绍了java 字段值为null,不返回该字段的问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-03-03
最新评论