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());
    }
}

您可能感兴趣的文章:

Java堆空间爆满导致宕机的问题分析及解决
团队有一个服务,一直运行的好好的,突然访问异常了,先是请求超时,然后直接无法访问,本文将给大家介绍Java堆空间爆满导致宕机的问题分析及解决,需要的朋友可以参考下
2024-02-02
详解Java POI excel自定义设置单元格格式
这篇文章主要介绍了Java POI excel设置单元格格式，自定义设置,设置单元格格式：来源_formats，更多数据类型从formats里面发现，需要的朋友可以参考下
2024-01-01
java 获取服务器真实IP的实例
这篇文章主要介绍了java 获取服务器真实IP的实例的相关资料,这里提供实现方法帮助大家学习理解这部分内容，需要的朋友可以参考下
2017-08-08
详解java之redis篇(spring-data-redis整合)
本篇文章主要介绍了java之redis篇，主要详细的介绍了spring-data-redis整合，有兴趣的可以了解一下。
2017-01-01
Java数据结构--时间和空间复杂度
这篇文章主要介绍了java数据结构的时间和空间复杂度,小编觉得这篇文写的不错，感兴趣的朋友可以了解下，希望能够给你带来帮助
2021-08-08
Java泛型机制与反射原理相关知识总结
今天带大家学习的是关于Java进阶的相关知识,文章围绕着Java泛型机制与反射原理展开,文中有非常详细的介绍及代码示例,需要的朋友可以参考下
2021-06-06
利用Java实现简单的猜数字小游戏
这篇文章主要为大家详细介绍了如何利用java语言实现猜数字小游戏，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-04-04
linux中nohup java -jar启动java项目的步骤
nohup是一个Unix和Linux命令,用于运行关闭时不会被终止的进程,这篇文章主要给大家介绍了关于linux中nohup java -jar启动java项目的相关资料,文中通过代码介绍的非常详细,需要的朋友可以参考下
2024-08-08
java数据结构之二分查找法 binarySearch的实例
这篇文章主要介绍了java数据结构之二分查找法 binarySearch的实例的相关资料,希望通过本文能帮助到大家，让大家理解掌握这部分内容，需要的朋友可以参考下
2017-10-10
springboot ElasticSearch如何配置自定义转换器ElasticsearchCustomConver
这篇文章主要介绍了springboot ElasticSearch如何配置自定义转换器ElasticsearchCustomConversions问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
2023-08-08

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

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具