java中thread的join方法為什么能讓線程插隊(duì)

oysun 發(fā)布于2019-08-19 11:40 / 1971人閱讀

摘要：接收到之后，會(huì)再次進(jìn)行判斷，死亡之后，就跳出循環(huán)，方法結(jié)束，之后就繼續(xù)執(zhí)行主線程中的其他代碼。同時(shí)我們也能看到方法里面能傳遞時(shí)間參數(shù)，大概作用就是等待指定時(shí)間之后，如果之前線程還未執(zhí)行完成，那么久不再等待。

在面試中經(jīng)常會(huì)遇到這樣的問(wèn)題：在主線程中有兩個(gè)子線程，如果能讓著兩個(gè)子線程能順序的執(zhí)行？
答案自然是用join來(lái)使得兩個(gè)線程順序執(zhí)行，先看一下具體代碼

public class ThreadOfJoin {

    public static void main(String[] args) throws Exception {
        MyThread luck = new MyThread("Luck");
        MyThread timi = new MyThread("Timi");

        luck.start();
        luck.join();
        timi.start();
    }

    @Data
    static class MyThread extends Thread {
        private String userName;
        public MyThread(String userName) {
            this.userName = userName;
        }

        @Override
        public void run() {
            try {
                for (int i = 0; i < 5; i++) {
                    System.out.println(userName + " - " + i);
                    Thread.sleep(1000);
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

}

每個(gè)線程啟動(dòng)后，打印五次信息，通過(guò)不同的名字來(lái)區(qū)分是哪個(gè)線程打印的。執(zhí)行結(jié)果如下

Luck - 0
Luck - 1
Luck - 2
Luck - 3
Luck - 4
Timi - 0
Timi - 1
Timi - 2
Timi - 3
Timi - 4

通過(guò)結(jié)果可以看到j(luò)oin可以使得兩個(gè)線程是順序執(zhí)行，那為什么join能控制線程順序執(zhí)行呢，我們看下join的具體實(shí)現(xiàn)

//外部調(diào)用的方法
public final void join() throws InterruptedException {
    join(0);
}
//內(nèi)部的具體實(shí)現(xiàn)
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;
        }
    }
}

首先join通過(guò)synchronized關(guān)鍵字來(lái)保證線程安全，主線程在調(diào)用了luck.start()之后調(diào)用了luck.join()，當(dāng)luck線程未執(zhí)行完成是，主線程會(huì)被以下代碼阻塞

if (millis == 0) {//join()方法默認(rèn)milis為0
    while (isAlive()) {//線程未執(zhí)行完成，此條件為true
        wait(0);//等待notify
    }
}

當(dāng)luck線程執(zhí)行完成之后，此線程的生命周期即將結(jié)束，在生命周期結(jié)束前，luck線程會(huì)使用notifyAll()方法，通知所有正在等待該對(duì)象鎖的線程(我即將死去，你們不要再等了)。wait(0)接收到notify之后，會(huì)再次進(jìn)行isAlive()判斷，luck死亡之后，就跳出循環(huán)，join方法結(jié)束，之后就繼續(xù)執(zhí)行主線程中的其他代碼。

同時(shí)我們也能看到j(luò)oin方法里面能傳遞時(shí)間參數(shù)，大概作用就是等待指定時(shí)間之后，如果之前線程還未執(zhí)行完成，那么久不再等待。