【多线程:join】join再理解

简介: 【多线程:join】join再理解

【多线程:join】join再理解

01.介绍

昨天我突然想到一个问题 join方法的底层实现是wait,执行wait的线程等待,那么它是怎么唤醒的呢?抱着这个问题我找了找博客最后发现了这篇文章https://blog.csdn.net/x541211190/article/details/109322537,这里面介绍了notifyAll的解锁时机,我发现了这么一段话在java中,Thread类线程执行完run()方法后,一定会自动执行notifyAll()方法 这句话如同醍醐灌顶,我立刻就理解了join方法里的wait是如何唤醒的了。
接下来我来模拟一下join的过程。

02.模拟

join源码


我们关注两个地方,第一是while循环条件 isAlive()它的作用是 判断调用join的线程是否存活 如果存活则执行wait()这里wait作用的线程是执行join的线程,注意这里 调用和执行的区别。举一个例子:我们在t2线程中执行了t1.join(),那么isAlive()判断的是t1线程是否存活,wait是让t2线程陷入等待

join例子

@Slf4j(topic = "c.TestInterJoin")
public class TestInterJoin {
    public static void main(String[] args) {
        Thread t1 = new Thread(()->{
            for (int i=0;i<5;i++){
                log.debug("t1");
            }
        },"t1");

        Thread t2 = new Thread(()->{
            try {
                t1.join();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            for (int i=0;i<5;i++){
                log.debug("t2");
            }
        },"t2");
        t2.start();
        t1.start();

    }
}

结果

15:08:50.125 c.TestInterJoin [t1] - t1
15:08:50.127 c.TestInterJoin [t1] - t1
15:08:50.127 c.TestInterJoin [t1] - t1
15:08:50.127 c.TestInterJoin [t1] - t1
15:08:50.127 c.TestInterJoin [t1] - t1
15:08:50.127 c.TestInterJoin [t2] - t2
15:08:50.128 c.TestInterJoin [t2] - t2
15:08:50.128 c.TestInterJoin [t2] - t2
15:08:50.128 c.TestInterJoin [t2] - t2
15:08:50.128 c.TestInterJoin [t2] - t2

解释
我们创建了两个线程 t1 t2,我们在t2线程中执行t1.join使得t1线程同步到t2线程,结果也能证明这个结论

用wait模拟join例子

@Slf4j(topic = "c.TestInterJoinMN")
public class TestInterJoinMN {
    public static void main(String[] args) {
        Thread t1 = new Thread(()->{
            Sleeper.sleep(2);
            for (int i=0;i<5;i++){
                log.debug("t1");
            }
        },"t1");

        Thread t2 = new Thread(()->{
            synchronized (t1){
                try {
                    t1.wait();
                } catch (InterruptedException e) {
                    e.pri(ntStackTrace();
                }
            }
            for (int i=0;i<5;i++){
                log.debug("t2");
            }
        },"t2");
        t2.start();
        t1.start();
    }
}

结果

15:12:16.361 c.TestInterJoinMN [t1] - t1
15:12:16.363 c.TestInterJoinMN [t1] - t1
15:12:16.363 c.TestInterJoinMN [t1] - t1
15:12:16.363 c.TestInterJoinMN [t1] - t1
15:12:16.363 c.TestInterJoinMN [t1] - t1
15:12:16.363 c.TestInterJoinMN [t2] - t2
15:12:16.363 c.TestInterJoinMN [t2] - t2
15:12:16.363 c.TestInterJoinMN [t2] - t2
15:12:16.363 c.TestInterJoinMN [t2] - t2
15:12:16.363 c.TestInterJoinMN [t2] - t2

解释
我们发现我们在t2线程创建了一个以 t1线程对象为监视器的锁,并执行了wait()方法导致t2线程陷入等待,此时如果我们没有notify或notifyAll方法的话 是不能唤醒t2线程的,但这里神奇的事情出现了 我们发现最终t2线程还是执行了。原因还是这句话在java中,Thread类线程执行完run()方法后,一定会自动执行notifyAll()方法,因为我们是把t1线程当成锁对象,但随着t1线程的运行结束 即run方法运行结束 t1线程执行了t1.notifyAll(),所以此时唤醒了 所有以t1为锁的线程,所以t2线程被唤醒了。这就是join的实现原理。

目录
相关文章
|
Java 程序员 调度
如何用Java编写代码来等待一个线程join()??
如何用Java编写代码来等待一个线程join()??
43 0
|
7月前
|
Java
在两道多线程基础题“顺序打印”中对比一下Java中的wait()和join()
这篇内容讨论了如何在Java中通过多线程控制特定顺序的打印任务。
56 0
|
程序员 调度
多线程的创建,复习匿名内部类,Thread的一些方法,以及lambda的变量捕捉,join用法(二)
多线程的创建,复习匿名内部类,Thread的一些方法,以及lambda的变量捕捉,join用法
|
前端开发 Java 程序员
多线程的创建,复习匿名内部类,Thread的一些方法,以及lambda的变量捕捉,join用法(一)
多线程的创建,复习匿名内部类,Thread的一些方法,以及lambda的变量捕捉,join用法
|
7月前
|
Java
学习多线程之join方法
学习多线程之join方法
83 0
|
7月前
|
NoSQL Java 程序员
多线程并发之线程池Executor与Fork/Join框架
多线程并发之线程池Executor与Fork/Join框架
95 0
|
数据采集 Python
等一等,你的多线程可别再乱 join 了。
等一等,你的多线程可别再乱 join 了。
90 0
|
Java 调度
69. 对并发熟悉吗?谈谈线程间的协作(wait/notify/sleep/yield/join)
69. 对并发熟悉吗?谈谈线程间的协作(wait/notify/sleep/yield/join)
59 1
69. 对并发熟悉吗?谈谈线程间的协作(wait/notify/sleep/yield/join)
【多线程】一文图解wait()、notify()、join()源码
这一篇我们主要是对wait()、notify()、join()进行图解,可能有些粗糙,不足之处多多指出。
|
Java 调度
join线程执行结束之后,并没有看到哪里有notify方法,请问此时谁去唤醒等待池中的线程
Java中的join方法,阻塞当前线程,直到join线程结束后才继续执行。底层是通过wait来实现的,join线程执行结束之后,并没有看到哪里有notify方法,请问此时谁去唤醒等待池中的线程(join之前的那个“当前”线程)呢?
105 0
join线程执行结束之后,并没有看到哪里有notify方法,请问此时谁去唤醒等待池中的线程