欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

Java多线程join方法分析

程序员文章站 2024-03-03 16:02:22
...

定义

首先看一下相关教材上怎么说的:如果一个线程A执行了thread.join()语句,其含义是:当前线程A等待thread线程终止后才从thread方法返回。

接下来我们直接看例子,不出意外,和我们预想的一样,线程A和线程B交替输出结果。

public class LockTest {
    public static void main(String[] args) throws InterruptedException {
        Thread A = new Thread(new Thread_(), "线程A");
        Thread B = new Thread(new Thread_(), "线程B");
        A.start();
//        A.join();
        B.start();

    }
}
class Thread_ implements Runnable{
    @Override
    public void run() {
        for (int i = 0; i < 5; i++) {
            System.out.println(Thread.currentThread().getName()+"---当前值是"+ i);
        }
    }
}
输出结果:
线程A---当前值是0
线程B---当前值是0
线程A---当前值是1
线程B---当前值是1
线程A---当前值是2
线程B---当前值是2
线程A---当前值是3
线程B---当前值是3
线程B---当前值是4
线程A---当前值是4

那么现在将A.join()注释取消,输出结果如下,这是为什么呢,为什么是线程A执行完毕后线程B才开始执行输出结果呢?注意,我们这里是在主程序main方法中调用了A.join()方法,按照教材定义就是main线程调用了A.join()语句,那么main线程会等待A线程中止后才会继续执行,也就是主线程走到A.join()这行代码时,就会把自己的线程挂起进行等待,等待A线程终止后才会继续往下走,所以接着执行B.start()。

再多说一句,这里线程A和线程B没有半毛钱关系,A和B都是主线程的子线程,它俩只会和主线程进行交互。不是有些文章中提到的B线程进入等待状态,等待A线程执行完才会自己执行。这是错的,好好看定义,在哪个线程中调用join方法,就是哪个线程挂起,等待使用join方法的线程执行完继续执行。

线程A---当前值是0
线程A---当前值是1
线程A---当前值是2
线程A---当前值是3
线程A---当前值是4
线程B---当前值是0
线程B---当前值是1
线程B---当前值是2
线程B---当前值是3
线程B---当前值是4

接着我们来说一些文章提到的这种情况:把A.jion()放到B.start(),也就是下面代码中的情况,输出结果是AB线程交替打印,有人说不理解,那我们继续分析,主线程开始执行,执行到A.start(),继续执行B.start(),这个时候AB两个线程已经开始执行,在控制台交替打印了,然后接着执行到A.join()方法,这个时候AB线程都已经开始执行,顺序是交替打印,再把主线程挂起已经没有任何意义了。

        ...省略
        A.start();
        B.start();
        A.join();
        ...省略
输出结果:
线程A---当前值是0
线程B---当前值是0
线程A---当前值是1
线程B---当前值是1
线程A---当前值是2
线程B---当前值是2
线程A---当前值是3
线程B---当前值是3
线程B---当前值是4
线程A---当前值是4

那我们接着再把程序改一下,主程序改成下面这样,接着上面的分析,在AB线程start()以后,接着执行A.join(),这个时候主线程挂起,只有等到A线程中止后才会接着执行for循环,再次强调,和B没关系,线程B爱什么时候输出什么时候输出,哪怕输出到for循环后面,当前在实际中也是不太可能。最后再把定义说一遍

结论

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

public static void main(String[] args) throws InterruptedException {
        Thread A = new Thread(new Thread_(), "线程A");
        Thread B = new Thread(new Thread_(), "线程B");
        A.start();
        B.start();
        A.join();
        for (int i = 0; i < 5; i++) {
            System.out.println(Thread.currentThread().getName()+"---当前值是"+ i);
        }

    }
输出结果:
线程A---当前值是0
线程B---当前值是0
线程A---当前值是1
线程B---当前值是1
线程A---当前值是2
线程B---当前值是2
线程A---当前值是3
线程A---当前值是4
线程B---当前值是3
线程B---当前值是4
main---当前值是0
main---当前值是1
main---当前值是2
main---当前值是3
main---当前值是4

 

 

 

 

相关标签: join