Java并发编程示例(六)：等待线程执行终止

更新时间：2014年12月05日 10:29:32 投稿：junjie

这篇文章主要介绍了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());
    }
}

您可能感兴趣的文章:

SpringCloud Bus消息总线的实现
消息总线是一种通信工具，可以在机器之间互相传输消息、文件等，这篇文章主要介绍了SpringCloud Bus消息总线的实现，Spring cloud bus 通过轻量消息代理连接各个分布的节点，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2018-05-05
openjdk与Oraclejdk的区别
这篇文章主要介绍了openjdk与Oraclejdk的区别，帮助大家更好的了解JAVA，感兴趣的朋友可以了解下
2020-08-08
Mybatis中xml的动态sql实现示例
本文主要介绍了Mybatis中xml的动态sql实现示例，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2022-06-06
java操作XML实例代码
这篇文章主要介绍了java操作XML实例代码，有需要的朋友可以参考一下
2014-01-01
Java的Hibernate框架中用于操作数据库的HQL语句讲解
这篇文章主要介绍了Java的Hibernate框架中用于操作数据库的HQL语句讲解,Hibernate是Java的SSH三大web开发框架之一,需要的朋友可以参考下
2016-01-01
Spring Boot与Kotlin 整合全文搜索引擎Elasticsearch的示例代码
本篇文章主要介绍了Spring Boot与Kotlin 整合全文搜索引擎Elasticsearch的示例代码，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2018-01-01
oracle数据库导入TXT文件方法介绍
这篇文章主要介绍了oracle数据库导入TXT文件方法介绍，文中向大家展示了具体代码示例，需要的朋友可以参考下。
2017-09-09
JVM内存区域划分相关原理详解
这篇文章主要介绍了JVM内存区域划分相关原理详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2020-10-10
快速了解hibernate配置文件与映射文件
这篇文章主要介绍了快速了解hibernate配置文件与映射文件，具有一定参考价值，需要的朋友可以了解下。
2017-10-10
springboot异常处理的基本规范
这篇文章主要给大家介绍了关于springboot异常处理的基本规范，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-11-11