join为啥会阻塞主线程？

join使用

上篇们介绍了CountDownLatch，顺便说到了Thread中的join方法！

import java.util.concurrent.TimeUnit;
/**
 * @author ：jiaolian
 * @date ：Created in 2021-02-28 21:43
 * @description：join测试
 * @modified By：
 * 公众号:叫练
 */
public class JoinTest {
    public static void main(String[] args) throws InterruptedException {
        Thread threadA = new Thread(()->{
            try {
                TimeUnit.SECONDS.sleep(2);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName()+":想先执行");
        },"线程A");
        //开启一个线程A
        threadA.start();
        //主线程会持有子线程的锁,子线程还没开始主线程就阻塞了,等待子线程结束后通知;
        threadA.join();
        System.out.println(Thread.currentThread().getName()+ "线程执行");
    }
}

如上代码所示：在JoinTest开启一个线程A，threadA调用join()方法，主线程会等待threadA执行完毕！也就是两秒后，主线程执行最后一句话，运行结果如下图所示！

们深入源码，join方法底层其实就是一个wait方法，但现在问题是：明明调用者是线程A，可阻塞的是mian线程，不应该阻塞的是threadA吗？

证明问题：明明调用者是线程A，可阻塞的是mian线程

们参照Thread中join源码，将上面的代码改造如下：

import java.util.concurrent.TimeUnit;
/**
 * @author ：jiaolian
 * @date ：Created in 2021-02-28 21:43
 * @description：join测试
 * @modified By：
 * 公众号:叫练
 */
public class JoinCodeTest {
    public static void main(String[] args) throws InterruptedException {
        MyThread threadA = new MyThread("线程A");
        //开启一个线程A
        threadA.start();
        //主线程会持有子线程的锁,子线程还没开始主线程就阻塞了,等待子线程结束后通知;
        threadA.join2(0);
        System.out.println(Thread.currentThread().getName()+ "线程执行");
    }
    private static class MyThread extends Thread {
        public MyThread(String name) {
            super(name);
        }
        @Override
        public void run() {
            try {
                TimeUnit.SECONDS.sleep(2);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName()+":想先执行");
        }
        //复制Thread源码中的join方法测试阻塞的是线程A还是main线程？
        public final synchronized void join2(long millis)
                throws InterruptedException {
            long base = System.currentTimeMillis();
            long now = 0;
            if (millis < 0) {
                throw new IllegalArgumentException("timeout value is negative");
            }
            if (millis == 0) {
                while (isAlive()) {
                    //虽然调用者是线程A，但真正执行阻塞的是main线程！
                    System.out.println(Thread.currentThread().getName()+"会阻塞");
                    wait(0);
                }
                while (isAlive()) {
                    long delay = millis - now;
                    if (delay <= 0) {
                        break;
                    }
                    wait(delay);
                    now = System.currentTimeMillis() - base;
                }
            }
        }
    }
}

如上代码所示：MyThread继承Thread，并复制了join源码，将join修改成join2，并在join2方法中增加了一个输出语句，System.out.println(Thread.currentThread().getName()+“会阻塞”)用来测试阻塞的是线程A还是main线程，所以在JoinCodeTest的main方法中ThreadA是调用join2方法，

结果发现进入join2方法的线程是main线程。运行结果如下图所示！

这里可以把join理解成一个普通方法！真正阻塞的不是调用者线程，而是当前正在执行的线程。

总结

今天们介绍了join方法，特别是将源码中代码copy出来证明测试，相信整理出来希望能对你有帮助，写的比不全，同时还有许多需要修正的地方，希望亲们加以指正和点评，喜欢的请点赞加关注哦。点关注，不迷路， 是【叫练 】公众号 ，微信号【jiaolian123abc】边叫边练。

[] ) [](top

原文创作：叫练

原文链接：https://www.cnblogs.com/jiaolian/p/14460995.html

文章列表

• 高效读书,实用阅读指南
• 面试官：你说说ReentrantLock和Synchronized区别
• 线程池面试必考
• 正月十五吃汤圆CountDownLatch
• 核酸检测：让我明白AQS原理
• 最简单的JVM内存结构图
• 我们一起学程序-五子棋
• 并发队列：PriorityBlockingQueue和DelayQueue案例使用
• 并发队列：ArrayBlockingQueue实际运用场景和原理
• 图解定时任务线程池
• 图解CyclicBarrier运动员接力赛
• 叫练手把手教你读JVM之GC信息
• 原来我还有网络天赋
• ||运算你真的了解吗？
• join为啥会阻塞主线程？
• indexOf原理，Java，javascript，python实现
• Semaphore实战
• ReentrantReadWriteLock读写锁简单原理案例证明
• Lamda拉姆达表达式演化过程
• Java通过socket和DTU,RTU连接工业传感器通信
• Java单例7种测试实践
• CopyOnWriteArrayList 读写分离，弱一致性
• CMS前世今生
• 2020回顾，2021学习目标