Java并發(fā)編程示例(六)：等待線程執(zhí)行終止

2019-11-26 15:20:33

字體：大中小

來源：轉(zhuǎn)載

供稿：網(wǎng)友

在某些場景下，我們必須等待線程執(zhí)行完成才能進行下一步工作。例如，某些程序在開始執(zhí)行之前，需要先初始化一些資源。這時，我們可以啟動一個線程專門來做初始化任務，等到線程任務完成后，再去執(zhí)行其他部分。

為此，Thread類為我們提供了join()方法。當我們使用線程對象調(diào)用此方法時，正在掉調(diào)用的線程對象將被推遲到被調(diào)用對象執(zhí)行完成后再開始執(zhí)行。

在本節(jié)，示例程序演示等待初始化方法完成后，再去執(zhí)行其他任務。

知其然

按照下面所示步驟，完成示例程序。

1.創(chuàng)建一個名為DataSourcesLoader的類，并且實現(xiàn)Runnable接口。代碼如下：

復制代碼代碼如下:

public class DataSourcesLoader implements Runnable {

2.實現(xiàn)run()方法，向控制臺打印出一條信息以說明開始執(zhí)行，然后睡眠4秒鐘，再向控制臺打印一條信息來說明線程執(zhí)行結(jié)束。代碼如下：

復制代碼代碼如下:

@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.創(chuàng)建一個名為NetworkConnectionsLoader的類，并且實現(xiàn)Runnable接口。實現(xiàn)run()方法，該方法代碼與DataSourcesLoader類的run()方法一樣，只是這個睡眠6秒鐘。

4.實現(xiàn)示例的主類，并且實現(xiàn)main()方法。代碼如下：

復制代碼代碼如下:

public class Main {
    public static void main(String[] args) {

5.創(chuàng)建一個DataSourcesLoader對象，以及一個啟動它執(zhí)行的Thread對象。代碼如下：

復制代碼代碼如下:

DataSourcesLoader dsLoader = new DataSourcesLoader();
Thread thread1 = new Thread(dsLoader, "DataSourcesLoader");

6.創(chuàng)建一個NetworkConnectionsLoader對象，以及一個啟動它執(zhí)行的Thread對象。代碼如下：

復制代碼代碼如下:

NetworkConnectionsLoader ncLoader = new NetworkConnectionsLoader();
Thread thread2 = new Thread(ncLoader, "NetworkConnectionsLoader");

7.調(diào)用兩個Thread對象的start()方法。代碼如下：

復制代碼代碼如下:

thread1.start();
thread2.start();

8.調(diào)用join()方法，來等待兩個線程完成其任務。這個方法會拋出InterruptedException異常，所以要捕獲該異常。代碼如下：

復制代碼代碼如下:

try {
    thread1.join();
    thread2.join();
} catch (InterruptedException e) {
    e.printStackTrace();
}

9.向控制臺打印一句話，表明程序執(zhí)行結(jié)束。代碼如下：

復制代碼代碼如下:

System.out.printf("Main: Configuration has been loaded: %s/n",
        new Date());

10.運行程序，查看執(zhí)行效果。

知其所以然

當運行這個示例程序時，我們可以看到兩個線程啟動了它們的執(zhí)行。首先，是DataSourcesLoader完成了它的執(zhí)行；然后，是NetworkConnectionsLoader完成了它的執(zhí)行。這時，主線程繼續(xù)它的執(zhí)行，然后向控制臺打印出終止信息。

永無止境

Java提供了另外兩種重載的join()方法：

復制代碼代碼如下:

join(long milliseconds)
join(long milliseconds, long nanos)

第一種方式，不會直到被調(diào)用完成任務，而是等待參數(shù)指定的時間后就開始執(zhí)行；例如，如果thread1調(diào)用該方法，thread1.join(1000)，當thread1線程滿足如下其中之一的條件就會繼續(xù)執(zhí)行：

1.thread2完成它的執(zhí)行；
2.1000毫秒過后；

當這兩個條件中的其中之一為真時，join()方法就會返回，開始繼續(xù)執(zhí)行原來的任務。

第二種方式的方法和第一種很類似，只是多了一個納秒級的時間參數(shù)。

拿來主義

本文是從《Java 7 Concurrency Cookbook》（D瓜哥竊譯為《Java7并發(fā)示例集》）翻譯而來，僅作為學習資料使用。沒有授權(quán)，不得用于任何商業(yè)行為。

小有所成

本節(jié)所用示例代碼的完整版。

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并發(fā)編程示例(七)：守護線程的創(chuàng)建和運行

下一篇：Java并發(fā)編程示例(五)：線程休眠與恢復