Java多線程-Thread.join()
Thread.join()把制定的線程加入到當(dāng)前線程坞嘀，可以將兩個(gè)交替執(zhí)行的多線程合并為順序執(zhí)行的線程轧膘。比如在線程B中調(diào)用累線程A的join()方法逆趋，直到線程A執(zhí)行完畢后，才會(huì)繼續(xù)執(zhí)行線程B;
eg:
線程A代碼：
public class A extends Thread{
@Override
? ? ? ? public void run() {
? ? ? ? ? ?for (int i =0; i <500 ; i++) {
? ? ? ? ?System.out.println("A--thread:"+i);
? ? ? ? ? ?}
}
}
線程B的代碼：
public class Bextends Thread {
@Override
? ? public void run() {
A a =new A();
a.start();
try {
? ? ? ? ? ?a.join();// 調(diào)用join方法
? ? ? ? ? ? for (int i =0; i <500 ; i++) {
? ? ? ? ?System.out.println("Thread-B:"+i);
}
}catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String[] args){
new B().start();
}
}
觀察結(jié)果：在線程B的run方法中啟動(dòng)類線程A的start方法和join()，打印的結(jié)果沒(méi)有交叉執(zhí)行匾乓÷济海可以得出上面的結(jié)論鳄厌。感興趣的同學(xué)可以將線程a.join()方法注視掉，觀看打印結(jié)果有沒(méi)有交叉執(zhí)行妈踊。???
結(jié)論：? ?當(dāng)我們調(diào)用某個(gè)線程的join這個(gè)方法時(shí)了嚎，這個(gè)方法會(huì)掛起調(diào)用線程，直到被調(diào)用線程結(jié)束執(zhí)行廊营，調(diào)用線程才會(huì)繼續(xù)執(zhí)行歪泳。
源碼解析：
Thread 源碼有3個(gè)join方法重載。
public final void join()throws InterruptedException {
join(0);
}露筒；
public final synchronized void join(long millis,int nanos)
throws InterruptedException {
if (millis <0) {
throw new IllegalArgumentException("timeout value is negative");
}
if (nanos <0 || nanos >999999) {
throw new IllegalArgumentException(
"nanosecond timeout value out of range");
}
if (nanos >=500000 || (nanos !=0 && millis ==0)) {
millis++;
}
join(millis);
}
public final synchronized void join(long millis)
throws InterruptedException {
long base = System.currentTimeMillis();
long now =0;
if (millis <0) {
throw new IllegalArgumentException("timeout value is negative");
}
if (millis ==0) {
while (isAlive()) {
wait(0);
}
}else {
while (isAlive()) {
long delay = millis - now;
if (delay <=0) {
break;
}
wait(delay);
now = System.currentTimeMillis() - base;
}
}
其中
a. join() 和 join(long millis, int nanos) 最后都調(diào)用了?join(long millis)呐伞。
b. 帶參數(shù)的 join() 都是 synchronized method。
c. join() 調(diào)用了 join(0)慎式，從源碼可以看到 join(0) 不斷檢查當(dāng)前線程（join() 所屬的線程實(shí)例伶氢，非調(diào)用線程）是否是 Active。
d. join() 和 sleep() 一樣瘪吏，都可以被中斷（被中斷時(shí)癣防，會(huì)拋出 InterrupptedException 異常）；不同的是肪虎，join() 內(nèi)部調(diào)用了 wait()劣砍，會(huì)出讓鎖，而 sleep() 會(huì)一直保持鎖扇救。
以本文開(kāi)頭的代碼為例刑枝，我們分析一下代碼邏輯：
B 調(diào)用 a.join()香嗓，a.join() 再調(diào)用 a.join(0) （此時(shí) B 會(huì)獲得 child 實(shí)例作為鎖，其他線程可以進(jìn)入 child.join() 装畅，但不可以進(jìn)入 child.join(0)(同步的)靠娱， 因?yàn)闊o(wú)法獲取鎖）。child.join(0) 會(huì)不斷地檢查 child 線程是否是 Active掠兄。
如果 child 線程是 Active像云，則循環(huán)調(diào)用 child.wait(0)（為了防止 Spurious wakeup, 需要將 wait(0) 放入 for 循環(huán)體中；此時(shí) B 會(huì)釋放 a 實(shí)例鎖蚂夕，其他線程可以競(jìng)爭(zhēng)鎖并進(jìn)入 a.join(0)迅诬。我們可以得知，可以有多個(gè)線程等待某個(gè)線程執(zhí)行完畢）婿牍。
一旦 a 線程不為 Active （狀態(tài)為 TERMINATED）, a.join(0) 會(huì)直接返回到 a.join(), a.join() 會(huì)直接返回到 B 父線程侈贷，B 父線程就可以繼續(xù)運(yùn)行下去了。
