JAVA多线程中join()方法的使用方法

虽然关于讨论线程join()方法博客已经非常极其特别多了,但是前几天我有一个困惑却没有能够得到详细解释,当系统中正在运行多个线程时,join()到底是暂停了哪些线程,所以本文详细解释一下希望能帮助到和我有相同困惑的同学

虽然关于讨论线程join()方法博客已经非常极其特别多了,但是前几天我有一个困惑却没有能够得到详细解释,就是当系统中正在运行多个线程时,join()到底是暂停了哪些线程,大部分博客给的例子看起来都像是t.join()方法会使所有线程都暂停并等待t的执行完毕。当然,这也是因为我对多线程中的各种方法和同步的概念都理解的不是很透彻。通过看别人的分析和自己的实践之后终于想明白了,详细解释一下希望能帮助到和我有相同困惑的同学。

首先给出结论:t.join()方法只会使主线程(或者说调用t.join()的线程)进入等待池并等待t线程执行完毕后才会被唤醒。并不影响同一时刻处在运行状态的其他线程。

下面则是分析过程。

之前对于join()方法只是了解它能够使得t.join()中的t优先执行,当t执行完后才会执行其他线程。能够使得线程之间的并行执行变成串行执行。

package CSDN; public class TestJoin { public static void main(String[] args) throws InterruptedException { // Todo Auto-generated method stub ThreadTest t1=new ThreadTest("A"); ThreadTest t2=new ThreadTest("B"); t1.start(); t2.start(); } } class ThreadTest extends Thread { private String name; public ThreadTest(String name){ this.name=name; } public void run(){ for(int i=1;i

运行结果:

A-1

B-1

B-2

B-3

A-2

B-4

A-3

B-5

A-4

A-5

可以看出A线程和B线程是交替执行的。

而在其中加入join()方法后(后面的代码都略去了ThreadTest类的定义)

package CSDN; public class TestJoin { public static void main(String[] args) throws InterruptedException { // Todo Auto-generated method stub ThreadTest t1=new ThreadTest("A"); ThreadTest t2=new ThreadTest("B"); t1.start(); t1.join(); t2.start(); } }

运行结果:

A-1

A-2

A-3

A-4

A-5

B-1

B-2

B-3

B-4

B-5

显然,使用t1.join()之后,B线程需要等A线程执行完毕之后才能执行。需要注意的是,t1.join()需要等t1.start()执行之后执行才有效果,此外,如果t1.join()放在t2.start()之后的话,仍然会是交替执行,然而并不是没有效果,这点困扰了我很久,也没在别的博客里看到过。

为了深入理解,我们先看一下join()的源码。

/** * Waits for this thread to die. * * An invocation of this method behaves in exactly the same * way as the invocation * *

* {@linkplain #join(long) join}{@code (0)} * * * @throws InterruptedException * if any thread has interrupted the current thread. The * interrupted status of the current thread is * cleared when this exception is thrown. */ public final void join() throws InterruptedException { join(0); //join()等同于join(0) } /** * Waits at most {@code millis} milliseconds for this thread to * die. A timeout of {@code 0} means to wait forever. * * This implementation uses a loop of {@code this.wait} calls * conditioned on {@code this.isAlive}. As a thread terminates the * {@code this.notifyAll} method is invoked. It is recommended that * applications not use {@code wait}, {@code notify}, or * {@code notifyAll} on {@code Thread} instances. * * @param millis * the time to wait in milliseconds * * @throws IllegalArgumentException * if the value of {@code millis} is negative * * @throws InterruptedException * if any thread has interrupted the current thread. The * interrupted status of the current thread is * cleared when this exception is thrown. */ public final synchronized void join(long millis) throws InterruptedException { long base = System.currentTimeMillis(); long Now = 0; if (millis

可以看出,join()方法的底层是利用wait()方法实现的。可以看出,join方法一个同步方法,当主线程调用t1.join()方法时,主线程先获得了t1对象的锁,随后进入方法调用了t1对象的wait()方法,使主线程进入了t1对象的等待池,此时,A线程则还在执行,并且随后的t2.start()还没被执行,因此,B线程也还没开始。等到A线程执行完毕之后,主线程继续执行,走到了t2.start(),B线程才会开始执行。

此外,对于join()的位置和作用的关系,我们可以用下面的例子来分析

package CSDN; public class TestJoin { public static void main(String[] args) throws InterruptedException { // Todo Auto-generated method stub System.out.println(Thread.currentThread().getName()+" start"); ThreadTest t1=new ThreadTest("A"); ThreadTest t2=new ThreadTest("B"); ThreadTest t3=new ThreadTest("C"); System.out.println("t1start"); t1.start(); System.out.println("t2start"); t2.start(); System.out.println("t3start"); t3.start(); System.out.println(Thread.currentThread().getName()+" end"); } }

运行结果为

main start

t1start

t1end

t2start

t2end

t3start

t3end

A-1

A-2

main end

C-1

C-2

C-3

C-4

C-5

A-3

B-1

B-2

B-3

B-4

B-5

A-4

A-5

A、B、C和主线程交替运行。加入join()方法

package CSDN; public class TestJoin { public static void main(String[] args) throws InterruptedException { // Todo Auto-generated method stub System.out.println(Thread.currentThread().getName()+" start"); ThreadTest t1=new ThreadTest("A"); ThreadTest t2=new ThreadTest("B"); ThreadTest t3=new ThreadTest("C"); System.out.println("t1start"); t1.start(); System.out.println("t1end"); System.out.println("t2start"); t2.start(); System.out.println("t2end"); t1.join(); System.out.println("t3start"); t3.start(); System.out.println("t3end"); System.out.println(Thread.currentThread().getName()+" end"); } }

运行结果:

main start

t1start

t1end

t2start

t2end

A-1

B-1

A-2

A-3

A-4

A-5

B-2

t3start

t3end

B-3

main end

B-4

B-5

C-1

C-2

C-3

C-4

C-5

多次实验可以看出,主线程在t1.join()方法处停止,并需要等待A线程执行完毕后才会执行t3.start(),然而,并不影响B线程的执行。因此,可以得出结论,t.join()方法只会使主线程进入等待池并等待t线程执行完毕后才会被唤醒。并不影响同一时刻处在运行状态的其他线程。

PS:join源码中,只会调用wait方法,并没有在结束时调用notify,这是因为线程在die的时候会自动调用自身的notifyAll方法,来释放所有的资源和锁。

到此这篇关于JAVA多线程中join()方法的使用方法文章就介绍到这了,更多相关JAVA多线程join()方法内容搜索编程之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程之家!

相关文章

HashMap是Java中最常用的集合类框架,也是Java语言中非常典型...
在EffectiveJava中的第 36条中建议 用 EnumSet 替代位字段,...
介绍 注解是JDK1.5版本开始引入的一个特性,用于对代码进行说...
介绍 LinkedList同时实现了List接口和Deque接口,也就是说它...
介绍 TreeSet和TreeMap在Java里有着相同的实现,前者仅仅是对...
HashMap为什么线程不安全 put的不安全 由于多线程对HashMap进...