Java Thread中join方法使用举例详解

前言

join() 方法是 Java 并发编程中一个非常重要且基础的方法，它允许一个线程等待另一个线程执行完成。理解它的工作原理和使用场景对于编写健壮的多线程应用程序至关重要。

1.join()方法的定义和作用

join() 是 java.lang.Thread 类的一个实例方法。它的核心作用是阻塞当前正在执行的线程（我们称之为“主线程”，尽管它可以是任何线程），直到调用 join() 方法的那个线程（我们称之为“目标线程”）执行完毕。

简单来说，如果线程 A 的代码中调用了线程 B 的 join() 方法（即 B.join()），那么线程 A 就会进入等待状态，直到线程 B 执行结束，线程 A 才会从 B.join() 这行代码继续往下执行。

这就像在一个接力赛中，下一棒的选手（线程 A）必须等待上一棒的选手（线程 B）跑完自己的赛程并交接后，才能开始跑。

2.join()方法的三个重载版本

Thread 类提供了三个版本的 join() 方法：

1. public final void join()

   • 这是最常用的版本。它会一直等待，直到目标线程执行完毕。
   • 它会抛出 InterruptedException，这意味着等待中的线程可能会被中断。

2. public final synchronized void join(long millis)

   • 这是一个带超时参数的版本。它会等待目标线程执行，但最多只等待指定的毫秒数。
   • 如果目标线程在指定的超时时间内执行完毕，当前线程会立即继续执行。
   • 如果超过了指定的毫秒数，目标线程还未执行完，当前线程也会停止等待，继续执行。
   • 同样会抛出 InterruptedException。

3. public final synchronized void join(long millis, int nanos)

   • 这个版本提供了更精确的超时控制，可以指定毫秒和纳秒。
   • 功能与 join(long millis) 类似，只是提供了更高精度的时间控制。

3.join()方法的工作原理 (深入分析)

你可能会好奇，join() 是如何实现线程等待的？它的底层原理是什么？

1. isAlive() 检查: 当你在线程 A 中调用 threadB.join() 时，join() 方法内部会首先检查 threadB 是否还活着 (isAlive())。如果 threadB 已经执行完毕（或者从未启动），isAlive() 会返回 false，那么 join() 方法会立即返回，线程 A 不会进行任何等待。

2. wait() 循环等待: 如果 isAlive() 返回 true，join() 方法会进入一个循环。在这个循环里，它会调用目标线程对象（threadB）的 wait() 方法。

   • 关键点: join() 方法是一个 synchronized 方法。当线程 A 调用 threadB.join() 时，它会获取 threadB 这个对象的锁。然后，join() 方法内部调用 threadB.wait()，这会导致线程 A 释放 threadB 的锁，并进入 threadB 对象的等待集（Wait Set）中，状态变为 WAITING 或 TIMED_WAITING。

3. JVM 负责唤醒: 当目标线程 threadB 的 run() 方法执行完毕，准备退出时，Java 虚拟机（JVM）会在其内部自动调用 threadB 的 notifyAll() 方法。

   • 这个 notifyAll() 会唤醒所有正在等待 threadB 对象锁的线程，当然也包括了之前因调用 join() 而等待的线程 A。

4. 重新获取锁并退出: 线程 A 被唤醒后，会尝试重新获取 threadB 的对象锁。一旦获取成功，它会从 wait() 方法返回，并退出 join() 的循环，从而结束等待，继续执行后续代码。

总结一下核心机制: join() 的实现巧妙地利用了 Java 的内置锁（synchronized）和 wait()/notifyAll() 协作机制。它将线程间的执行顺序问题，转化为了经典的“生产者-消费者”模式中的线程同步问题。

4. 为什么要使用join()？使用场景

join() 的主要应用场景是协调线程间的执行顺序。当你需要确保一个或多个前置任务（在子线程中执行）完成后，主线程才能继续执行后续任务时，join() 就非常有用。

常见场景:

• 数据初始化: 主线程启动多个子线程去分别加载不同的资源或执行初始化计算。主线程需要等待所有初始化工作完成后，才能使用这些资源去执行核心业务逻辑。
• 分块处理: 一个大任务被拆分成多个小任务，每个小任务交给一个子线程处理。主线程需要等待所有子线程处理完毕后，对结果进行汇总和合并。
• 确保流程顺序: 在一个复杂的业务流程中，步骤 B 必须在步骤 A 执行完毕后才能开始。如果 A 和 B 在不同的线程中，那么 B 所在的线程就需要 join() A 所在的线程。

5. 代码示例

示例 1: 等待单个线程

public class JoinExample {
    public static void main(String[] args) throws InterruptedException {
        System.out.println("主线程开始运行...");

        Thread workerThread = new Thread(() -> {
            System.out.println("子线程开始工作...");
            try {
                // 模拟耗时操作
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("子线程工作完成。");
        });

        workerThread.start(); // 启动子线程

        System.out.println("主线程调用 join() 等待子线程...");
        workerThread.join(); // 关键：主线程在此处阻塞，等待 workerThread 执行完毕

        System.out.println("主线程在子线程完成后继续运行。");
    }
}

输出:

主线程开始运行...
主线程调用 join() 等待子线程...
子线程开始工作...
// (等待约 2 秒)
子线程工作完成。
主线程在子线程完成后继续运行。

示例 2: 等待多个线程

public class MultiJoinExample {
    public static void main(String[] args) throws InterruptedException {
        System.out.println("主线程开始...");

        Thread t1 = new Thread(() -> {
            System.out.println("线程1 开始处理...");
            try { Thread.sleep(1000); } catch (InterruptedException e) {}
            System.out.println("线程1 处理完毕。");
        });

        Thread t2 = new Thread(() -> {
            System.out.println("线程2 开始处理...");
            try { Thread.sleep(2000); } catch (InterruptedException e) {}
            System.out.println("线程2 处理完毕。");
        });

        // 启动所有线程
        t1.start();
        t2.start();

        System.out.println("主线程等待所有子线程完成...");

        // 等待 t1 和 t2
        t1.join();
        t2.join();

        System.out.println("所有子线程处理完毕，主线程继续执行。");
    }
}

输出:

主线程开始...
主线程等待所有子线程完成...
线程1 开始处理...
线程2 开始处理...
// (等待约 1 秒)
线程1 处理完毕。
// (再等待约 1 秒)
线程2 处理完毕。
所有子线程处理完毕，主线程继续执行。

6.InterruptedException的处理

join() 方法会抛出 InterruptedException。这是因为正在等待的线程（调用 join() 的线程）自身可能会被其他线程中断 (interrupt())。

当一个线程在 join() 等待期间被中断时，join() 方法会立即抛出 InterruptedException。在 catch 块中，通常需要处理这个中断信号。一个好的实践是重新设置当前线程的中断状态，以便上层调用者能够知道发生了中断。

try {
    workerThread.join();
} catch (InterruptedException e) {
    // 捕获到中断异常
    System.out.println("主线程在等待期间被中断了！");
    // 恢复中断状态，这是一种良好的编程实践
    Thread.currentThread().interrupt();
}

总结

到此这篇关于Java Thread中join方法使用的文章就介绍到这了,更多相关Java Thread中join方法使用内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

最新评论