join()——化多线程并发执行为顺序执行

多线程并发比较常见，但很多时候一个线程的输入可能非常依赖于另外一个线程的输出，此时这个线程就需要等待依赖线程执行完毕再执行。通俗的说，就是合并多个路径为单一路径，变多线程并发为单线程顺序执行。JDK提供了Join()这个Ｔｈｒｅａｄ类的实例方法来达到这个要求。

join——英文含义为加入，通俗的说就是将一个线程合并到另一个线程。但是还有以下几个问题：

哪个线程加入？

加入到哪个线程?

加入后的效果是啥?

通过下面一段代码可以进行验证：

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，再ｊｏｉｎ
th.start();
th.join();
System.out.println(i);
}
}

执行结果为：１０００００

验证后可以回答上面三个问题了。

哪个线程加入？——>调用Join()函数的那个对象开启的线程，注意要先开启线程，才能加入ｓｔａｒｔ，也就是ｓｔａｒｔ（）方法要在ｊｏｉｎ（）方法前面。本例中是

JoinTest

加入到哪个线程？——>加入到当前线程，通俗的说在哪个线程中执行该函数的，就加入哪个线程。

本例中是

main

加入后的效果？——＞阻塞当前线程，直到加入的线程执行完，当前线程继续执行。

ｊｏｉｎ的本质是让当前线程ｗａｉｔ（）在调用ｊｏｉｎ方法的那个线程实例的锁上，等到那个线程实例开启的线程跑完，再ｎｏｔｉｆｙ（）当前线程继续执行。下面是ＪＤＫ中ｊｏｉｎ（）实现的核心代码片段：

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");
／／过期时间为０
if (paramLong == 0L)
while (true) {
／／ｉｓAｌｉｖｅ（）是一个实例方法，用来判断线程（不是当前ｍａｉｎ线程，
／／而是含有该方法的线程实例ＪｏｉｎＴｅｓｔ启动的那个线程）是否存活，通俗的说就是ｒｕｎ方法有没有跑完
if (!(isAlive()))
return;
／／这里是关键，同步方法内调用锁对象的ｗａｉｔ（）方法阻塞当前线程
／／可能这里会有疑问，阻塞的难道不是ＪｏｉｎＴｅｓｔ线程吗？你看，是ＪｏｉｎＴｅｓｔ对象里的方法
／／是不是ＪｏｉｎＴｅｓｔ线程要看它在不在ｒｕｎ方法里面，这个函数在ｒｕｎ方法里面吗？显然不是
super.wait(0L);／／被合并线程未结束，当前线程继续等待
}
while (isAlive()) {
long l3 = paramLong - l2;
if (l3 <= 0L)
return;
super.wait(l3);
l2 = System.currentTimeMillis() - l1;
}
}

之后的流程我们也能猜到，被合并的线程执行完后，会ｎｏｔｉｆｙ（）【其实这里是ｎｏｔｉｆｙａｌｌ（）】等待线程继续执行。