Java 中的 Thread.join() 方法详解

在多线程编程中，线程的管理和协调是一个重要课题。Java 提供了多种机制来实现线程之间的协调，其中之一就是方法。join()方法允许一个线程等待另一个线程完成，这在很多场景中是非常有用的。例如，当我们需要确保某个任务在继续之前必须先完成另一个任务时，join()方法就是一个很好的选择。

csdn_life18

2062人浏览 · 2024-06-07 10:41:24

csdn_life18 · 2024-06-07 10:41:24 发布

介绍

本文基于 Java 8 进行编写，可能与您使用的 Java 版本有所不同，请注意版本差异。

在多线程编程中，线程的管理和协调是一个重要课题。Java 提供了多种机制来实现线程之间的协调，其中之一就是 Thread.join() 方法。join() 方法允许一个线程等待另一个线程完成，这在很多场景中是非常有用的。例如，当我们需要确保某个任务在继续之前必须先完成另一个任务时，join() 方法就是一个很好的选择。

代码演示

为了更好地理解 join() 方法的使用，我们来看一个简单的代码示例。

public class JoinExample extends Thread {
    public void run() {
        for(int i = 1; i <= 5; i++) {
            try {
                Thread.sleep(500);
            } catch(InterruptedException e) {
                System.out.println(e);
            }
            System.out.println(i);
        }
    }

    public static void main(String[] args) {
        JoinExample t1 = new JoinExample();
        JoinExample t2 = new JoinExample();
        JoinExample t3 = new JoinExample();
        
        t1.start();
        try {
            t1.join();
        } catch(InterruptedException e) {
            System.out.println(e);
        }
        
        t2.start();
        t3.start();
    }
}

在上述代码中，主线程启动了 JoinExample 线程 t1，并调用了 t1.join()，这使得主线程在 t1 完成之前不会继续执行。当 t1 完成后，主线程才会继续启动 t2 和 t3。

`join()` 工作机制

join() 方法让调用线程进入等待状态，直到目标线程完成或者被中断。其内部实现依赖于 Object 类的 wait() 方法，因此在等待期间调用线程会释放 CPU 资源，以便其他线程能够执行。通过调用 join() 方法，可以确保一个线程的执行顺序，这在某些需要依赖线程执行结果的场景中非常重要。

`join()` 源码解析

在 Java 8 中，Thread.join() 的源码如下：

public final synchronized void join(long millis) throws InterruptedException {
    // 记录当前时间的基准时间
    long base = System.currentTimeMillis();
    long now = 0;

    // 如果传入的超时时间为负数，则抛出非法参数异常
    if (millis < 0) {
        throw new IllegalArgumentException("timeout value is negative");
    }

    // 如果传入的超时时间为0，表示无限等待，直到目标线程结束
    if (millis == 0) {
        while (isAlive()) {
            // 无限期等待目标线程结束
            wait(0);
        }
    } else {
        // 如果传入的超时时间大于0，则在目标线程结束或者超时时间到达之前等待
        while (isAlive()) {
            // 计算剩余的等待时间
            long delay = millis - now;
            if (delay <= 0) {
                // 如果剩余时间小于等于0，跳出循环
                break;
            }
            // 等待剩余时间
            wait(delay);
            // 更新当前时间
            now = System.currentTimeMillis() - base;
        }
    }
}

join 方法是 Java 中 Thread 类提供的一个关键方法，用于使一个线程等待另一个线程的完成。在实现上，join 方法通过调用 Object 类的 wait 方法实现了等待机制。其逻辑可以分为以下几步：

记录当前的基准时间，用于后续计算等待时间。
检查传入的超时时间是否为负数，若是则抛出异常。
根据传入的超时时间，决定是进行无限等待还是有限等待：
- 若超时时间为0，则无限期等待目标线程结束。
- 若超时时间大于0，则计算剩余的等待时间，并在目标线程结束或超时前等待。

通过这些步骤，join 方法能够灵活地处理不同的等待时间，并在目标线程结束或者指定的超时时间到达之前，将调用线程置于等待状态。这一机制在多线程编程中非常有用，特别是在需要确保某个线程在继续执行之前等待另一个线程完成的场景下。

`join()` 和 `wait()` 的对比研究

定义：
- join() 是 Thread 类的方法，用于等待另一个线程完成。
- wait() 是 Object 类的方法，用于使线程等待某个条件发生。
使用场景：
- join() 通常用于一个线程等待另一个线程完成。
- wait() 通常与 notify() 和 notifyAll() 一起使用，用于线程间的通信。
锁定：
- join() 内部使用 wait() 实现，因此会释放持有的锁。
- wait() 需要在同步块中调用，同样会释放锁。

`join()` 方法的常见使用场景

线程依赖关系：当一个线程的执行依赖于另一个线程的完成时，可以使用 join() 方法。例如，在并行处理多个任务时，主线程可能需要等待所有子线程完成后再继续执行。
- Fork/Join 框架：在并行计算中，将任务拆分成子任务，主线程等待所有子任务完成后再继续执行。
- Spring 异步任务处理：在使用 @Async 注解时，主线程需要等待所有异步任务完成后再继续执行。
- Apache Spark 分布式计算：在分布式数据处理任务中，主线程需要等待所有子任务完成后再汇总结果。
- Java Concurrency (ExecutorService)：在并行任务处理中，主线程需要等待所有线程池中的任务完成后再继续执行。
同步初始化：在某些情况下，某个线程需要初始化一些资源，其他线程需要等待这些资源初始化完成后才能继续工作。这时可以使用 join() 方法来实现同步初始化。
- Spring Framework：在使用异步任务时，主线程需要等待资源初始化完成后才能继续执行其他任务。
- Hibernate：初始化数据库连接或 SessionFactory 时，主线程需要等待这些初始化操作完成后，才能进行数据库操作。
- Apache Hadoop：初始化 HDFS 文件系统或 MapReduce 框架时，线程需要等待资源初始化完成后，才能开始数据处理任务。
- Apache Kafka：启动消费者和生产者时，消费者线程需要等待生产者初始化 Kafka 连接和主题配置完成后，才能开始消费消息。
- Android：在 Android 应用开发中，UI 线程需要等待后台线程初始化数据或加载资源完成后，才能进行界面更新操作。
- Java EE (Jakarta EE)：初始化 JNDI 资源或启动 EJB 容器时，其他线程需要等待这些资源初始化完成后，才能进行后续操作。
简化复杂流程控制：在复杂的多线程流程中，使用 join() 可以简化线程之间的协调和控制，确保流程按预期进行。
- Fork/Join 框架：在处理分而治之的任务时，使用 join() 可以简化任务分割和结果合并的控制流程。
- Spring Batch：在批处理任务中，主线程需要等待所有步骤完成后再进行下一步操作，确保批处理流程的有序进行。
- Apache Kafka：在消费者和生产者处理流程中，使用 join() 确保消息处理的顺序和数据的一致性。
- Java Concurrency (ExecutorService)：在复杂的并发任务处理流程中，使用 join() 可以协调多个线程的执行顺序，确保任务按预期进行。