你好，我是 shengjk1，多年大厂经验，努力构建 通俗易懂的、好玩的编程语言教程。 欢迎关注！你会有如下收益：

1. 了解大厂经验
2. 拥有和大厂相匹配的技术等

希望看什么，评论或者私信告诉我！

---

一、前言

前面的几篇文章我们分别讲解了java多线程的基础知识、java 线程之间通信-volatile 和 synchronized 以及 java线程间的通信- notify和 wait本篇是java多线程通信的最后一篇：join 和 ThreadLocal

二、join 和 ThreadLocal

2.1 join 介绍

2.1.1 join 作用和例子

如果一个线程A执行了thread.join()语句，其含义是：当前线程A等待thread线程终止之后才从thread.join() 返回。
如：

public class ThreadJoin1 {
    public static void main(String[] args) throws InterruptedException {
        Thread thread = new Thread("threadB") {
            @Override
            public void run() {
                try {
                    TimeUnit.SECONDS.sleep(10);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

            }
        };
        thread.start();

        thread.join();
        System.out.println("threadB执行完成，主线程继续往下执行");
    }
}

这里主线程会一直等待threadB执行完成，才能继续往下执行

2.1.2 join 其他方法

线程Thread除了提供join()方法之外，还提供了join(long millis)和join(long millis,int nanos)两个具备超时特性的方法。这两个超时方法表示，如果线程thread在给定的超时时间里没有终止，那么将会从该超时方法中返回

2.1.3 join 原理

//当 join 的时间为 0 时
if (millis == 0) {
    while (isAlive()) {
        wait(0);
    }
} else {
    while (isAlive()) {
        long delay = millis - now;
        if (delay <= 0) {
            break;
        }
        wait(delay);
        now = System.currentTimeMillis() - base;
    }
}

1. 等待线程终止：join()方法是用于让当前线程等待调用该方法的线程执行完毕。主调用线程会等待被调用线程的终止。具体来说，调用join(millis)方法会使当前线程最多等待millis毫秒，直到被调用线程结束，设定超时为0表示永久等待，而不是等待当前线程自己终止。
2. 实现机制：join()方法的实现通常会使用this.wait()方法，顺序地调用this.wait()，并检查this.isAlive()条件，以等待被调用线程的终止。当被调用线程终止时，会调用notifyAll()方法来唤醒正在等待的线程，让其继续执行。
3. 虽然源代码中无法找到join()方法内部的notifyAll()调用，但可以肯定的是，Java的多线程机制会确保在目标线程执行结束时，等待的线程能够被正确唤醒。这种机制是由Java运行时环境在底层实现的

2.1.4 join 的使用场景

join() 方法是用于让一个线程等待另一个线程完成的方法。在Java中，join() 方法通常用于以下应用场景：

1. 等待线程完成后再执行后续操作：当一个线程需要等待另一个线程执行完成后才能继续执行，可以使用 join() 方法。这在需要线程间协作的情况下很有用。
2. 多个线程按顺序执行：如果有多个线程按照一定的顺序来执行，可以使用 join() 方法使得后续的线程等待前一个线程完成之后再执行。
3. 线程任务协调：当一个线程需要等待其他一组线程都完成后才能继续执行时，在这组线程中每个线程可以在执行完自己的任务后调用join()方法，主线程会等待所有这些线程执行完毕。
4. 实现线程间的数据交换：通过join()方法，一个线程可以等待另一个线程计算出结果或者产生数据，从而实现多个线程间的数据交换。
5. 任务分解：在复杂的任务分解中，join() 可以用来等待各个子任务完成，然后汇总结果。 举例来说，假设我们有一个主线程，需要等待两个子线程完成后再继续执行，可以这样实现：

public class JoinExample {
    public static void main(String[] args) {
        Thread thread1 = new Thread(() -> {
            // 执行一些任务
            System.out.println("Thread 1 finished");
        });

        Thread thread2 = new Thread(() -> {
            // 执行一些任务
            System.out.println("Thread 2 finished");
        });

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

        try {
            thread1.join(); // 主线程等待thread1完成
            thread2.join(); // 主线程等待thread2完成
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        // 所有线程都执行完毕后继续执行主线程
        System.out.println("All threads have finished");
    }
}

在这个例子中，主线程会等待thread1 和 thread2 完成后才会继续执行。这种方式可以用于确保线程间的操作顺序性以及线程完成后的后续处理。

2.2 ThreadLocal 介绍

2.2.1 ThreadLocal 作用和例子

ThreadLocal，即线程变量( 可以理解为是线程的私有变量，每个线程一个所以不存在线程安全的问题 )，是一个以ThreadLocal对象为键、任意对象为值的存储结构。这个结构被附带在线程上，也就是说一个线程可以根据一个ThreadLocal对象查询到绑定在这个线程上的一个值。

public class MyThreadLocalExample {
    private static ThreadLocal<Integer> threadLocal = new ThreadLocal<>();

    public static void main(String[] args) {
        threadLocal.set(100);  // 在当前线程设置值
        System.out.println("Main Thread Value: " + threadLocal.get());

        Thread thread = new Thread(() -> {
            threadLocal.set(200);  // 在新线程设置值
            System.out.println("Child Thread Value: " + threadLocal.get());
        });

        thread.start();
    }
}

可以通过set(T)方法来设置一个值，在当前线程下再通过get()方法获取到原先设置的值

2.2.2 ThreadLocal 原理

ThreadLocal原理主要涉及Java内存模型中的“线程封闭”概念和ThreadLocal类的设计。

1. 每个线程都有自己的ThreadLocalMap： 在Java中，每个线程都维护着一个ThreadLocalMap对象，其中存储了线程本地变量的键值对。这个ThreadLocalMap在Thread类中以ThreadLocal.ThreadLocalMap类型的成员变量存在。

2. ThreadLocal作为 ThreadLocalMap 键： 当一个ThreadLocal对象被设置为线程的局部变量时，它实际上是作为ThreadLocalMap的键，而对应的值则是线程特定的变量。

3. 支持多个ThreadLocal变量： 每个线程可以同时持有多个ThreadLocal对象，每个ThreadLocal对象对应一个特定的线程局部变量。

4. ThreadLocalMap的查找和存储机制： 当线程需要获取ThreadLocal变量时，会先访问自己的ThreadLocalMap，根据ThreadLocal对象找到对应的值。如果没有找到，会创建一个新的Entry并存储到ThreadLocalMap中。

通过这种设计，ThreadLocal实现了线程封闭性和线程间变量隔离，为多线程环境下共享变量带来了一种简洁、安全的解决方案。

2.2.3 ThreadLocal 的使用场景

ThreadLocal 是一个线程本地变量工具类，它提供了线程级别的数据隔离，每个线程都可以拥有自己独立的变量副本。ThreadLocal 的使用场景包括但不限于：

1. 保存线程相关的上下文信息：在多线程环境中，有些信息是针对每个线程独立存在的，比如用户身份信息、数据库连接、请求参数等。ThreadLocal 可以用于保存这些线程相关的上下文信息，避免在线程之间相互干扰。
2. 提升性能：在某些情况下，对于频繁访问的对象，可以将其放入 ThreadLocal 中以减少方法参数传递和数据共享的开销，从而提升性能。
3. 跟踪日志：可以利用 ThreadLocal 在日志中添加线程标识符，用于追踪不同线程产生的日志信息，方便日志分析和调试。
4. 缓存数据：在某些情况下，需要对一些数据进行缓存，而这些数据是与线程相关的，可以使用 ThreadLocal 存储这些线程私有的缓存数据。
5. Web开发中的用户会话管理：在 Web 开发中，可以使用 ThreadLocal 存储用户的会话信息，确保每个用户的会话在不同请求之间得到正确管理。

如,在一个多线程的 Web 应用中，需要持续跟踪用户的登录状态：

public class UserContext {
    private static ThreadLocal<User> userThreadLocal = new ThreadLocal<>();

    public static void setUser(User user) {
        userThreadLocal.set(user);
    }

    public static User getUser() {
        return userThreadLocal.get();
    }

    public static void clear() {
        userThreadLocal.remove();
    }
}

// 在某个地方设置用户信息
User currentUser = userService.getCurrentUser();
UserContext.setUser(currentUser);

// 在其他地方获取用户信息
User loggedInUser = UserContext.getUser();

2.2.4 ThreadLocal 注意

ThreadLocalMap 中的 entry 继承了 WeakReference，在内存不足的时候，ThreadLocalMap 中的数据会被自动回收,所以在使用的时候要注意处理空值情况

static class Entry extends WeakReference<ThreadLocal<?>> {
    /** The value associated with this ThreadLocal. */
    Object value;

    Entry(ThreadLocal<?> k, Object v) {
        super(k);
        value = v;
    }
}

三、总结

本文详细介绍了join方法的使用方法、原理和适用场景，强调了其在多线程编程中的重要性。同时，ThreadLocal的工作原理和实际应用场景也得到了阐述，特别是在数据隔离和性能优化方面的作用。