Thread.join() 的使用

如果一个线程A执行了thread.join()语句，其含义是：当前线程A等待thread线程终止之后才

从thread.join()返回。线程Thread除了提供join()方法之外，还提供了join(long millis)和join(long

millis,int nanos)两个具备超时特性的方法。这两个超时方法表示，如果线程thread在给定的超时

时间里没有终止，那么将会从该超时方法中返回。

在代码清单所示的例子中，创建了10个线程，编号0~9，每个线程调用前一个线程的

join()方法，也就是线程0结束了，线程1才能从join()方法中返回，而线程0需要等待main线程结

束。

public class JoinDemo {

public static void main(String[] args) throws InterruptedException {
//获取当前线程信息
Thread previousThread= Thread.currentThread();
for(int i=0;i<10;i++){
Thread thread=new Thread(new Domino(previousThread));
thread.start();
previousThread=thread;
}
TimeUnit.SECONDS.sleep(5);
System.out.println("Thread.currentThread().getName()+\" terminate.\" = " + Thread.currentThread().getName()+" terminate.");

}

static class Domino implements Runnable{
private Thread thread;
public Domino(Thread thread){
this.thread=thread;
}
@Override
public void run() {
try {
thread.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + " terminate.");
}
}
}

输出如下：

Thread.currentThread().getName()+" terminate." = main terminate.
Thread-0 terminate.
Thread-1 terminate.
Thread-2 terminate.
Thread-3 terminate.
Thread-4 terminate.
Thread-5 terminate.
Thread-6 terminate.
Thread-7 terminate.
Thread-8 terminate.
Thread-9 terminate.

从上述输出可以看到，每个线程终止的前提是前驱线程的终止，每个线程等待前驱线程

终止后，才从join()方法返回，这里涉及了等待/通知机制（等待前驱线程结束，接收前驱线程结

束通知）。

// 加锁当前线程对象

public final synchronized void join() throws InterruptedException {

// 条件不满足，继续等待

while (isAlive()) {

wait(0);

}

// 条件符合，方法返回

}

当线程终止时，会调用线程自身的notifyAll()方法，会通知所有等待在该线程对象上的线

程。可以看到join()方法的逻辑结构的等待/通知经典范式一致，即加锁、循环

和处理逻辑3个步骤。