多线程并发比较常见,但不少时候一个线程的输入可能很是依赖于另一个线程的输出,此时这个线程就须要等待依赖线程执行完毕再执行。通俗的说,就是合并多个路径为单一路径,变多线程并发为单线程顺序执行。JDK提供了Join()这个Thread类的实例方法来达到这个要求。java
join——英文含义为加入,通俗的说就是将一个线程合并到另外一个线程。可是还有如下几个问题:多线程
哪一个线程加入?并发
加入到哪一个线程?
ide
加入后的效果是啥?函数
经过下面一段代码能够进行验证:spa
public class JoinTest extends Thread { private static int i = 0; @Override public void run() { while (i < 100000) { i++; } } public static void main(String[] args) throws Exception { Thread th = new JoinTest(); //注意:必须先start,再join th.start(); th.join(); System.out.println(i); } }
执行结果为:100000 线程
验证后能够回答上面三个问题了。code
哪一个线程加入?——>调用Join()函数的那个对象开启的线程,注意要先开启线程,才能加入start,也就是start()方法要在join()方法前面。本例中是对象
JoinTest
加入到哪一个线程?——>加入到当前线程,通俗的说在哪一个线程中执行该函数的,就加入哪一个线程。同步
本例中是
main
加入后的效果?——>阻塞当前线程,直到加入的线程执行完,当前线程继续执行。
join的本质是让当前线程wait()在调用join方法的那个线程实例的锁上,等到那个线程实例开启的线程跑完,再notify()当前线程继续执行。下面是JDK中join()实现的核心代码片断:
public final synchronized void join(long paramLong) throws InterruptedException { long l1 = System.currentTimeMillis(); long l2 = 0L; if (paramLong < 0L) throw new IllegalArgumentException("timeout value is negative"); //过时时间为0 if (paramLong == 0L) while (true) { //isAlive()是一个实例方法,用来判断线程(不是当前main线程, //而是含有该方法的线程实例JoinTest启动的那个线程)是否存活,通俗的说就是run方法有没有跑完 if (!(isAlive())) return; //这里是关键,同步方法内调用锁对象的wait()方法阻塞当前线程 //可能这里会有疑问,阻塞的难道不是JoinTest线程吗?你看,是JoinTest对象里的方法 //是否是JoinTest线程要看它在不在run方法里面,这个函数在run方法里面吗?显然不是 super.wait(0L);//被合并线程未结束,当前线程继续等待 } while (isAlive()) { long l3 = paramLong - l2; if (l3 <= 0L) return; super.wait(l3); l2 = System.currentTimeMillis() - l1; } }
以后的流程咱们也能猜到,被合并的线程执行完后,会notify()【其实这里是notifyall()】等待线程继续执行。