ALL is Well！

一、在研究join的用法之前，先明確兩件事情。

1.join方法定義在Thread類中，則調(diào)用者必須是一個線程，

例如：

Thread t = new CustomThread();//這里一般是自定義的線程類

t.start();//線程起動

t.join();//此處會拋出InterruptedException異常

2.上面的兩行代碼也是在一個線程里面執(zhí)行的。

以上出現(xiàn)了兩個線程，一個是我們自定義的線程類，我們實現(xiàn)了run方法，做一些我們需要的工作；另外一個線程，生成我們自定義線程類的對象，然后執(zhí)行

customThread.start();

customThread.join();

在這種情況下，兩個線程的關(guān)系是一個線程由另外一個線程生成并起動，所以我們暫且認為第一個線程叫做“子線程”，另外一個線程叫做“主線程”。

二、為什么要用join()方法

主線程生成并起動了子線程，而子線程里要進行大量的耗時的運算(這里可以借鑒下線程的作用)，當主線程處理完其他的事務(wù)后，需要用到子線程的處理結(jié)果，這個時候就要用到j(luò)oin();方法了。

三、join方法的作用

在網(wǎng)上看到有人說“將兩個線程合并”。這樣解釋我覺得理解起來還更麻煩。不如就借鑒下API里的說法：

“等待該線程終止。”

解釋一下，是主線程(我在“一”里已經(jīng)命名過了)等待子線程的終止。也就是在子線程調(diào)用了join()方法后面的代碼，只有等到子線程結(jié)束了才能執(zhí)行。(Waits for this thread to die.)

四、用實例來理解

寫一個簡單的例子來看一下join()的用法，一共三個類：

1.CustomThread 類

2. CustomThread1類

3. JoinTestDemo 類，main方法所在的類。

代碼1：

 1package wxhx.csdn2;   
 2/** *//**  
 3 *   
 4 * @author bzwm  
 5 *  
 6 */  
 7class CustomThread1 extends Thread {   
 8    public CustomThread1() {   
 9        super("[CustomThread1] Thread");   
10    };   
11    public void run() {   
12        String threadName = Thread.currentThread().getName();   
13        System.out.println(threadName + " start.");   
14        try {   
15            for (int i = 0; i < 5; i++) {   
16                System.out.println(threadName + " loop at " + i);   
17                Thread.sleep(1000);   
18            }   
19            System.out.println(threadName + " end.");   
20        } catch (Exception e) {   
21            System.out.println("Exception from " + threadName + ".run");   
22        }   
23    }   
24}   
25class CustomThread extends Thread {   
26    CustomThread1 t1;   
27    public CustomThread(CustomThread1 t1) {   
28        super("[CustomThread] Thread");   
29        this.t1 = t1;   
30    }   
31    public void run() {   
32        String threadName = Thread.currentThread().getName();   
33        System.out.println(threadName + " start.");   
34        try {   
35            t1.join();   
36            System.out.println(threadName + " end.");   
37        } catch (Exception e) {   
38            System.out.println("Exception from " + threadName + ".run");   
39        }   
40    }   
41}   
42public class JoinTestDemo {   
43    public static void main(String[] args) {   
44        String threadName = Thread.currentThread().getName();   
45        System.out.println(threadName + " start.");   
46        CustomThread1 t1 = new CustomThread1();   
47        CustomThread t = new CustomThread(t1);   
48        try {   
49            t1.start();   
50            Thread.sleep(2000);   
51            t.start();   
52            t.join();//在代碼2里，將此處注釋掉   
53        } catch (Exception e) {   
54            System.out.println("Exception from main");   
55        }   
56        System.out.println(threadName + " end!");   
57    }   
58}

打印結(jié)果：

main start.//main方法所在的線程起動，但沒有馬上結(jié)束，因為調(diào)用t.join();，所以要等到t結(jié)束了，此線程才能向下執(zhí)行。

[CustomThread1] Thread start.//線程CustomThread1起動

[CustomThread1] Thread loop at 0//線程CustomThread1執(zhí)行

[CustomThread1] Thread loop at 1//線程CustomThread1執(zhí)行

[CustomThread] Thread start.//線程CustomThread起動，但沒有馬上結(jié)束，因為調(diào)用t1.join();，所以要等到t1結(jié)束了，此線程才能向下執(zhí)行。

[CustomThread1] Thread loop at 2//線程CustomThread1繼續(xù)執(zhí)行

[CustomThread1] Thread loop at 3//線程CustomThread1繼續(xù)執(zhí)行

[CustomThread1] Thread loop at 4//線程CustomThread1繼續(xù)執(zhí)行

[CustomThread1] Thread end. //線程CustomThread1結(jié)束了

[CustomThread] Thread end.// 線程CustomThread在t1.join();阻塞處起動，向下繼續(xù)執(zhí)行的結(jié)果

main end!//線程CustomThread結(jié)束，此線程在t.join();阻塞處起動，向下繼續(xù)執(zhí)行的結(jié)果。

修改一下代碼，得到代碼2：(這里只寫出修改的部分)

 1public class JoinTestDemo {   
 2    public static void main(String[] args) {   
 3        String threadName = Thread.currentThread().getName();   
 4        System.out.println(threadName + " start.");   
 5        CustomThread1 t1 = new CustomThread1();   
 6        CustomThread t = new CustomThread(t1);   
 7        try {   
 8            t1.start();   
 9            Thread.sleep(2000);   
10            t.start();   
11//          t.join();//在代碼2里，將此處注釋掉   
12        } catch (Exception e) {   
13            System.out.println("Exception from main");   
14        }   
15        System.out.println(threadName + " end!");   
16    }   
17}

打印結(jié)果：

main start. // main方法所在的線程起動，但沒有馬上結(jié)束，這里并不是因為join方法，而是因為Thread.sleep(2000);

[CustomThread1] Thread start. //線程CustomThread1起動

[CustomThread1] Thread loop at 0//線程CustomThread1執(zhí)行

[CustomThread1] Thread loop at 1//線程CustomThread1執(zhí)行

main end!// Thread.sleep(2000);結(jié)束，雖然在線程CustomThread執(zhí)行了t1.join();，但這并不會影響到其他線程(這里main方法所在的線程)。

[CustomThread] Thread start. //線程CustomThread起動，但沒有馬上結(jié)束，因為調(diào)用t1.join();，所以要等到t1結(jié)束了，此線程才能向下執(zhí)行。

[CustomThread1] Thread loop at 2//線程CustomThread1繼續(xù)執(zhí)行

[CustomThread1] Thread loop at 3//線程CustomThread1繼續(xù)執(zhí)行

[CustomThread1] Thread loop at 4//線程CustomThread1繼續(xù)執(zhí)行

[CustomThread1] Thread end. //線程CustomThread1結(jié)束了

[CustomThread] Thread end. // 線程CustomThread在t1.join();阻塞處起動，向下繼續(xù)執(zhí)行的結(jié)果

五、從源碼看join()方法

在CustomThread的run方法里，執(zhí)行了t1.join();，進入看一下它的JDK源碼：

1public final void join() throws InterruptedException {   
2join(0);   
3}  

然后進入join(0)方法：

 1   /** *//**  
 2    * Waits at most <code>millis</code> milliseconds for this thread to   
 3    * die. A timeout of <code>0</code> means to wait forever. //注意這句  
 4    *  
 5    * @param      millis   the time to wait in milliseconds.  
 6    * @exception  InterruptedException if another thread has interrupted  
 7    *             the current thread.  The <i>interrupted status</i> of the  
 8    *             current thread is cleared when this exception is thrown.  
 9    */  
10   public final synchronized void join(long millis) //參數(shù)millis為0.   
11   throws InterruptedException {   
12long base = System.currentTimeMillis();   
13long now = 0;   
14if (millis < 0) {   
15           throw new IllegalArgumentException("timeout value is negative");   
16}   
17if (millis == 0) {//進入這個分支   
18    while (isAlive()) {//判斷本線程是否為活動的。這里的本線程就是t1.   
19    wait(0);//阻塞   
20    }   
21} else {   
22    while (isAlive()) {   
23    long delay = millis - now;   
24    if (delay <= 0) {   
25        break;   
26    }   
27    wait(delay);   
28    now = System.currentTimeMillis() - base;   
29    }   
30}   
31   } 

單純從代碼上看，如果線程被生成了，但還未被起動，調(diào)用它的join()方法是沒有作用的。將直接繼續(xù)向下執(zhí)行，這里就不寫代碼驗證了。

----2009年02月12日