當前位置:才華齋>計算機>java語言>

java基本教程之join方法的詳解

java語言 閱讀(3.22W)

本章涉及到的內容包括:

java基本教程之join方法的詳解

1. join()介紹

2. join()原始碼分析(基於JDK1.7.0_40)

3. join()示例

1. join()介紹

join() 定義在中。

join() 的作用:讓“主線程”等待“子執行緒”結束之後才能繼續執行。這句話可能有點晦澀,我們還是通過例子去理解:

複製程式碼 程式碼如下:

// 主執行緒

public class Father extends Thread {

public void run() {

Son s = new Son();

t();

();

...

}

}

// 子執行緒

public class Son extends Thread {

public void run() {

...

}

}

說明:

上面的有兩個類Father(主執行緒類)和Son(子執行緒類)。因為Son是在Father中建立並啟動的,所以,Father是主執行緒類,Son是子執行緒類。

在Father主執行緒中,通過new Son()新建“子執行緒s”。接著通過t()啟動“子執行緒s”,並且呼叫()。在呼叫()之後,Father主執行緒會一直等待,直到“子執行緒s”執行完畢;在“子執行緒s”執行完畢之後,Father主執行緒才能接著執行。 這也就是我們所說的“join()的作用,是讓主執行緒會等待子執行緒結束之後才能繼續執行”!

2. join()原始碼分析(基於JDK1.7.0_40)

複製程式碼 程式碼如下:

public final void join() throws InterruptedException {

join(0);

}

public final synchronized void join(long millis)

throws InterruptedException {

long base = entTimeMillis();

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 = entTimeMillis() - base;

}

}

}

說明:

從程式碼中,我們可以發現。當millis==0時,會進入while(isAlive())迴圈;即只要子執行緒是活的`,主執行緒就不停的等待。

我們根據上面解釋join()作用時的程式碼來理解join()的用法!

問題:

雖然()被呼叫的地方是發生在“Father主執行緒”中,但是()是通過“子執行緒s”去呼叫的join()。那麼,join()方法中的isAlive()應該是判斷“子執行緒s”是不是Alive狀態;對應的wait(0)也應該是“讓子執行緒s”等待才對。但如果是這樣的話,()的作用怎麼可能是“讓主執行緒等待,直到子執行緒s完成為止”呢,應該是讓"子執行緒等待才對(因為呼叫子執行緒物件s的wait方法嘛)"?

答案:wait()的作用是讓“當前執行緒”等待,而這裡的“當前執行緒”是指當前在CPU上執行的執行緒。所以,雖然是呼叫子執行緒的wait()方法,但是它是通過“主執行緒”去呼叫的;所以,休眠的是主執行緒,而不是“子執行緒”!

3. join()示例

在理解join()的作用之後,接下來通過示例檢視join()的用法。

複製程式碼 程式碼如下:

// 的原始碼

public class JoinTest{

public static void main(String[] args){

try {

ThreadA t1 = new ThreadA("t1"); // 新建“執行緒t1”

t(); // 啟動“執行緒t1”

(); // 將“執行緒t1”加入到“主執行緒main”中,並且“主執行緒main()會等待它的完成”

tf("%s finishn", entThread()ame());

} catch (InterruptedException e) {

tStackTrace();

}

}

static class ThreadA extends Thread{

public ThreadA(String name){

super(name);

}

public void run(){

tf("%s startn", ame());

// 延時操作

for(int i=0; i<1000000; i++)

;

tf("%s finishn", ame());

}

}

}

執行結果:

複製程式碼 程式碼如下:

t1 start

t1 finish

main finish

結果說明:

執行流程如圖

(01) 在“主執行緒main”中通過 new ThreadA("t1") 新建“執行緒t1”。 接著,通過 t() 啟動“執行緒t1”,並執行()。

(02) 執行()之後,“主執行緒main”會進入“阻塞狀態”等待t1執行結束。“子執行緒t1”結束之後,會喚醒“主執行緒main”,“主執行緒”重新獲取cpu執行權,繼續執行。