02.25 實現線程的方式到底有幾種?

這篇文章主要講解實現線程的方式到底有幾種?以及實現 Runnable 接口究竟比繼承 Thread 類實現線程好在哪裡?

實現線程是併發編程中基礎中的基礎,因為我們必須要先實現多線程,才可以繼續後續的一系列操作。所以本文就先從併發編程的基礎如何實現線程開始講起。

實現線程的方式到底有幾種?我們接下來看看它們具體指什麼?

實現 Runnable 接口


<code>public class RunnableThread implements Runnable {    @Override    public void run() {        System.out.println("實現Runnable接口實現線程");    }}/<code>

第 1 種方式是通過實現 Runnable 接口實現多線程,如代碼所示,首先通過 RunnableThread 類實現 Runnable 接口,然後重寫 run() 方法,之後只需要把這個實現了 run() 方法的實例傳到 Thread 類中就可以實現多線程。

繼承 Thread 類


<code>public class ExtendsThread extends Thread {         @Override    public void run() {        System.out.println(“繼承Thread類實現線程");    }}/<code>

第 2 種方式是繼承 Thread 類,如代碼所示,與第 1 種方式不同的是它沒有實現接口,而是繼承 Thread 類,並重寫了其中的 run() 方法。相信上面這兩種方式你一定非常熟悉,並且經常在工作中使用它們。

線程池創建線程

那麼為什麼說還有第 3 種或第 4 種方式呢?我們先來看看第 3 種方式:通過線程池創建線程。線程池確實實現了多線程,比如我們給線程池的線程數量設置成 10,那麼就會有 10 個子線程來為我們工作,接下來,我們深入解析線程池中的源碼,來看看線程池是怎麼實現線程的?

<code>static class DefaultThreadFactory implements ThreadFactory {    private static final AtomicInteger poolNumber = new AtomicInteger(1);    private final ThreadGroup group;    private final AtomicInteger threadNumber = new AtomicInteger(1);    private final String namePrefix;    DefaultThreadFactory() {        SecurityManager s = System.getSecurityManager();        group = (s != null) ? s.getThreadGroup() :                                Thread.currentThread().getThreadGroup();        namePrefix = "pool-" +                        poolNumber.getAndIncrement() +                        "-thread-";    }    public Thread newThread(Runnable r) {        Thread t = new Thread(group, r,                                namePrefix + threadNumber.getAndIncrement(),                                0);        if (t.isDaemon())            t.setDaemon(false);        if (t.getPriority() != Thread.NORM_PRIORITY)            t.setPriority(Thread.NORM_PRIORITY);        return t;    }}/<code>

對於線程池而言,本質上是通過線程工廠創建線程的,默認採用 DefaultThreadFactory ,它會給線程池創建的線程設置一些默認值,比如:線程的名字、是否是守護線程,以及線程的優先級等。但是無論怎麼設置這些屬性,最終它還是通過 new Thread() 創建線程的 ,只不過這裡的構造函數傳入的參數要多一些,由此可以看出通過線程池創建線程並沒有脫離最開始的那兩種基本的創建方式,因為本質上還是通過 new Thread() 實現的。

除此之外,Callable 也是可以創建線程的,但是本質上也是通過前兩種基本方式實現的線程創建。

有返回值的 Callable 創建線程


<code>class CallableTask implements Callable<integer> {    @Override    public Integer call() throws Exception {        return new Random().nextInt();    }}//創建線程池ExecutorService service = Executors.newFixedThreadPool(10);//提交任務,並用 Future提交返回結果Future<integer> future = service.submit(new CallableTask());/<integer>/<integer>/<code> 

第 4 種線程創建方式是通過有返回值的 Callable 創建線程,Runnable 創建線程是無返回值的,而 Callable 和與之相關的 Future、FutureTask,它們可以把線程執行的結果作為返回值返回,如代碼所示,實現了 Callable 接口,並且給它的泛型設置成 Integer,然後它會返回一個隨機數。

但是,無論是 Callable 還是 FutureTask,它們首先和 Runnable 一樣,都是一個任務,是需要被執行的,而不是說它們本身就是線程。它們可以放到線程池中執行,如代碼所示, submit() 方法把任務放到線程池中,並由線程池創建線程,不管用什麼方法,最終都是靠線程來執行的,而子線程的創建方式仍脫離不了最開始講的兩種基本方式,也就是實現 Runnable 接口和繼承 Thread 類。

除了上述常用的實現線程的方式還有以下方式:

定時器 Timer


<code>class TimerThread extends Thread {    boolean newTasksMayBeScheduled = true;    private TaskQueue queue;    TimerThread(TaskQueue queue) {        this.queue = queue;    }    public void run() {        try {            mainLoop();        } finally {            synchronized(queue) {                newTasksMayBeScheduled = false;                queue.clear();            }        }    }    private void mainLoop() {        while (true) {            try {                TimerTask task;                boolean taskFired;                synchronized(queue) {                    while (queue.isEmpty() && newTasksMayBeScheduled)                        queue.wait();                    if (queue.isEmpty())                        break;                    long currentTime, executionTime;                    task = queue.getMin();                    synchronized(task.lock) {                        if (task.state == TimerTask.CANCELLED) {                            queue.removeMin();                            continue;                        }                        currentTime = System.currentTimeMillis();                        executionTime = task.nextExecutionTime;                        if (taskFired = (executionTime<=currentTime)) {                            if (task.period == 0) {                                queue.removeMin();                                task.state = TimerTask.EXECUTED;                            } else {                                queue.rescheduleMin(                                  task.period<0 ? currentTime   - task.period                                                : executionTime + task.period);                            }                        }                    }                    if (!taskFired)                        queue.wait(executionTime - currentTime);                }                if (taskFired)                    task.run();            } catch(InterruptedException e) {            }        }    }}/<code>

定時器也可以實現線程,如果新建一個 Timer,令其每隔 10 秒或設置兩個小時之後,執行一些任務,那麼這時它確實也創建了線程並執行了任務,但如果我們深入分析定時器的源碼會發現,本質上它還是會有一個繼承自 Thread 類的 TimerThread,所以定時器創建線程最後又繞回到最開始說的兩種方式。

匿名內部類創建線程


<code>new Thread(new Runnable() {    @Override    public void run() {        System.out.println(Thread.currentThread().getName());    }}).start();/<code>

還有通過匿名內部類或 lambda 表達式方式來創建線程,實際上,匿名內部類或 lambda 表達式創建線程,它們僅僅是在語法層面上實現了線程,並不能把它歸結於實現多線程的方式,如匿名內部類實現線程的代碼所示,它僅僅是用一個匿名內部類把需要傳入的 Runnable 給實例出來。

<code>new Thread(() -> System.out.println(Thread.currentThread().getName())).start();/<code>

我們再來看下 lambda 表達式方式。如代碼所示,最終它們依然符合最開始所說的那兩種實現線程的方式。

實現線程只有一種方式

我們先不認為創建線程只有一種方式,先認為有兩種創建線程的方式,而其他的創建方式,比如線程池或是定時器,它們僅僅是在 new Thread() 外做了一層封裝,如果我們把這些都叫作一種新的方式,那麼創建線程的方式便會千變萬化、層出不窮,比如 JDK 更新了,它可能會多出幾個類,會把 new Thread() 重新封裝,表面上看又會是一種新的實現線程的方式,透過現象看本質,打開封裝後,會發現它們最終都是基於 Runnable 接口或繼承 Thread 類實現的。

接下來,我們進行更深層次的探討,為什麼說這兩種方式本質上是一種呢?

首先,啟動線程需要調用 start() 方法,而 start() 方法最終還會調用 run() 方法,我們先來看看第一種方式中 run() 方法究竟是怎麼實現的:

<code>@Overridepublic void run() {    if (target != null) {        target.run();    }}/<code>

可以看出 run() 方法的代碼非常短小精悍,第 1 行代碼 if (target != null) ,判斷 target 是否等於 null,如果不等於 null,就執行第 2 行代碼 target.run(),而 target 實際上就是一個 Runnable,即使用 Runnable 接口實現線程時傳給 Thread 類的對象。

然後,我們來看第二種方式,也就是繼承 Thread 方式,實際上,繼承 Thread 類之後,會把上述的 run() 方法重寫,重寫後 run() 方法裡直接就是所需要執行的任務,但它最終還是需要調用 thread.start() 方法來啟動線程,而 start() 方法最終也會調用這個已經被重寫的 run() 方法來執行它的任務,這時我們就可以徹底明白了,事實上創建線程只有一種方式,就是構造一個 Thread 類,這是創建線程的唯一方式。

我們上面已經瞭解了兩種創建線程方式本質上是一樣的,它們的不同點僅僅在於實現線程運行內容的不同,那麼運行內容來自於哪裡呢?

運行內容主要來自於兩個地方,要麼來自於 target,要麼來自於重寫的 run() 方法,在此基礎上我們進行拓展,可以這樣描述:本質上,實現線程只有一種方式,而要想實現線程執行的內容,卻有兩種方式,也就是可以通過實現 Runnable 接口的方式,或是繼承 Thread 類重寫 run() 方法的方式,把我們想要執行的代碼傳入,讓線程去執行,在此基礎上,如果我們還想有更多實現線程的方式,比如線程池和 Timer 定時器,只需要在此基礎上進行封裝即可。

實現 Runnable 接口比繼承 Thread 類實現線程要好

下面我們來對剛才說的兩種實現線程內容的方式進行對比,也就是為什麼說實現 Runnable 接口比繼承 Thread 類實現線程要好?好在哪裡呢?

首先,我們從代碼的架構考慮,實際上,Runnable 裡只有一個 run() 方法,它定義了需要執行的內容,在這種情況下,實現了 Runnable 與 Thread 類的解耦,Thread 類負責線程啟動和屬性設置等內容,權責分明。

第二點就是在某些情況下可以提高性能,使用繼承 Thread 類方式,每次執行一次任務,都需要新建一個獨立的線程,執行完任務後線程走到生命週期的盡頭被銷燬,如果還想執行這個任務,就必須再新建一個繼承了 Thread 類的類,如果此時執行的內容比較少,比如只是在 run() 方法裡簡單打印一行文字,那麼它所帶來的開銷並不大,相比於整個線程從開始創建到執行完畢被銷燬,這一系列的操作比 run() 方法打印文字本身帶來的開銷要大得多,相當於撿了芝麻丟了西瓜,得不償失。如果我們使用實現 Runnable 接口的方式,就可以把任務直接傳入線程池,使用一些固定的線程來完成任務,不需要每次新建銷燬線程,大大降低了性能開銷。

第三點好處在於 Java 語言不支持雙繼承,如果我們的類一旦繼承了 Thread 類,那麼它後續就沒有辦法再繼承其他的類,這樣一來,如果未來這個類需要繼承其他類實現一些功能上的拓展,它就沒有辦法做到了,相當於限制了代碼未來的可拓展性。

綜上所述,我們應該優先選擇通過實現 Runnable 接口的方式來創建線程。

總結

本文主要學習了通過 Runnable 接口和繼承 Thread 類等幾種方式創建線程,又詳細分析了為什麼說本質上只有一種實現線程的方式,以及實現 Runnable 接口究竟比繼承 Thread 類實現線程好在哪裡?看完本文相信你一定對創建線程有了更深入的理解。


分享到:


相關文章: