文章簡介

這一篇主要圍繞執行緒狀態控制相關的操作分析執行緒的原理，比如執行緒的中斷，執行緒的通訊等，內容比較多，可能會分兩篇文章

內容導航

• 執行緒的啟動的實現原理
• 執行緒停止的實現原理分析
• 為什麼中斷執行緒會丟擲InterruptedException的

一、執行緒的啟動原理

前面我們簡單分析過了執行緒的使用，通過呼叫執行緒的啟動方法來啟動執行緒，執行緒啟動後會呼叫執行方法執行業務邏輯，執行方法執行完畢後，執行緒的生命週期也就終止了。

很多同學最早學習執行緒的時候會比較疑惑，啟動一個執行緒為什麼是呼叫啟動方法，而不是執行方法，這做一個簡單的分析，先簡單看一下啟動方法的定義

 

我們看到呼叫啟動方法實際上是呼叫一個本地方法START0（）來啟動一個執行緒，首先START0（）這個方法是線上程的靜態塊中來註冊的，程式碼如下

 

這個registerNatives的作用是註冊一些本地方法提供給執行緒類來使用，比如START0（），的IsAlive（），currentThread（），睡眠（）;這些都是大家很熟悉的方法。

registerNatives的本地方法的定義在檔案Thread.cThread.c定義了各個作業系統平臺要用的關於執行緒的公共資料和操作，以下是Thread.c的全部內容

 

從這段程式碼可以看出，start0（），實際會執行JVM_StartThread方法，這個方法是幹嘛的呢？從名字上來看，似乎是在JVM層面去啟動一個執行緒，如果真的是這樣，那麼在JVM層面，一定會呼叫的Java中定義的執行方法那接下來繼續去找找答案我們找到。這個檔案，這個檔案需要下載熱點的原始碼才能找到。jvm.cpp

推薦一個交流學習交流圈子：142019080

 

JVM_ENTRY用來的英文定義JVM_StartThread函式的，在這個函式裡面建立了一個真正和平臺有關的本地執行緒。本著打破砂鍋查到底的原則，看看繼續做了什麼事情，繼續尋找JavaThread的定義newJavaThread

在熱點原始碼的中檔案中1558行的位置可以找到如下程式碼thread.cpp

 

這個方法有兩個引數，第一個是函式名稱，執行緒建立成功之後會根據這個函式名稱呼叫對應的函式;第二個是當前程序內已經有的執行緒數量最後我們重點關注與一下，實際就是呼叫平臺建立執行緒的方法來建立執行緒。os::create_thread

接下來就是執行緒的啟動，會呼叫Thread.cpp檔案中的Thread :: start（Thread * thread）方法，程式碼如下

 

啟動方法中有一個函式呼叫：，呼叫平臺啟動執行緒的方法，最終會呼叫Thread.cpp檔案中的JavaThread :: run（）方法os::start_thread(thread);

 

這個方法中主要是做一系列的初始化操作，最後有一個方法thread_main_inner，接下來看看這個方法的邏輯是什麼樣的

 

和主流程無關的程式碼咱們先不去看，直接找到最核心的程式碼塊，這個入口點應該比較熟悉了，因為我們在前面提到了，在:: JavaThread這個方法中傳遞的第一個引數，代表函式名稱，執行緒啟動的時候會呼叫這個函式。this->entry_point()(this,this);

如果大家還沒有暈車的話，應該記得我們在jvm.cpp檔案中看到的程式碼，在建立的時候傳遞了一個執行緒native_thread=newJavaThread(&thread_entry,sz);入口函式，所以我們在jvm.cpp中找到這個函式的定義如下

 

看到可以這個呼叫，其實就是通過回撥方法呼叫Java的執行緒中定義的執行方法，是一個巨集定義，在vmSymbols.hpp檔案中可以找到如下程式碼vmSymbols::run_method_name()run_method_name

 

所以結論就是，Java的裡面建立執行緒之後必須要呼叫啟動方法才能真正的建立一個執行緒，該方法會呼叫虛擬機器啟動一個本地執行緒，本地執行緒的建立會呼叫當前系統建立執行緒的方法進行建立，並且執行緒被的執行會時候回撥run方法進行業務邏輯的處理

二、執行緒的終止方法及原理

執行緒的終止有主動和被動之分，被動表示執行緒出現異常退出或者執行方法執行完畢，執行緒會自動終止。主動的方式的英文來實現執行緒的終止，但是停止（）方法是一個過期的方法，官方是不建議使用，理由很簡單，stop（）方法在中介一個執行緒時不會保證執行緒的資源正常釋放，也就是不會給執行緒完成資源釋放工作的機會，相當於我們在linux上通過kill -9強制結束一個程序。Thread.stop()

那麼如何安全的終止一個執行緒呢？

我們先看一下下面的程式碼，程式碼演示了一個正確終止執行緒的方法，至於它的實現原理，稍後我們再分析

 

程式碼中有兩處需要注意，在主執行緒中，呼叫了執行緒的中斷（）方法，在執行方法中，而中迴圈通過來判斷執行緒中斷的標識。所以我們在這裡猜想一下，應該是線上程中維護了一箇中斷標識，通過方法去改變了中斷標識的值使得方法中，而迴圈的判斷不成立而跳出迴圈，因此執行方法執行完畢以後執行緒就終止了執行。Thread.currentThread().isInterrupted()thread.interrupt()

推薦一個交流學習交流圈子：142019080

執行緒中斷的原理分析

來看我們一下方法做了什麼事情thread.interrupt()

 

這個方法裡面，呼叫了中斷0（），這個方法在前面分析啟動方法的時候見過，是一個本機方法，這裡就不再重複貼程式碼了，同樣，我們找到jvm.cpp檔案，找到JVM_Interrupt的定義

 

這個方法比較簡單，呼叫直接了這個方法，這個方法的定義在Thread.cpp檔案中，程式碼如下Thread::interrupt(thr)

 

主題::中斷方法呼叫了OS ::中斷方法，這個是呼叫平臺的中斷方法，方法這個實現的的英文在檔案中，其中星號代表的是不同平臺，因為JVM是跨平臺的，所以對於不同的操作平臺，執行緒的排程方式都是不一樣的。我們以os_linux.cpp檔案為例os_*.cpp

 

通過上面的程式碼分析可以知道，了Thread.interrupt（）方法實際就是設定一箇中斷狀態標識為真，並且通過ParkEvent的取消駐留方法來喚醒執行緒。

• 對於同步阻塞的執行緒，被喚醒以後會繼續嘗試獲取鎖，如果失敗仍然可能被公園
• 在呼叫ParkEvent的公園方法之前，會先判斷執行緒的中斷狀態，如果為真，會清除當前執行緒的中斷標識
• 的Object.wait，了Thread.sleep，的Thread.join會丟擲InterruptedException的

這裡給大家普及一個知識點，為什麼的Object.wait，的Thread.sleep和的Thread.join都會丟擲InterruptedException的？首先，這個異常的意思是表示一個阻塞被其他執行緒中斷了。然後，由於執行緒呼叫了中斷（）中斷方法，那麼的Object.wait，的Thread.sleep等被阻塞的執行緒被喚醒以後會通過is_interrupted方法判斷中斷標識的狀態變化，如果發現中斷標識為真，則先清除中斷標識，然後丟擲InterruptedException的

需要注意的是，InterruptedException的異常的丟擲並不意味著執行緒必須終止，而是提醒當前執行緒有中斷的操作發生，至於接下來怎麼處理取決於執行緒本身，比如

• 直接捕獲異常不做任何處理
• 將異常往外丟擲
• 停止當前執行緒，並列印異常資訊

為了讓大家能夠更好的理解上面這段話，我們以了Thread.sleep為例直接從JDK的原始碼中找到中斷標識的清除以及異常丟擲的方法程式碼

找到方法，LINUX平臺中的實現在os_linux.cpp檔案中，程式碼如下is_interrupted()

 

找到了Thread.sleep這個操作在JDK中的原始碼體現，怎麼找？相信如果前面大家有認真看的話，應該能很快找到，程式碼在jvm.cpp檔案中

 

注意上面加了中文註釋的地方的程式碼，先判斷is_interrupted的狀態，然後丟擲一個InterruptedException的異常。到此為止，我們就已經分析清楚了中斷的整個流程。

Java的執行緒的中斷標識判斷

瞭解了了Thread.interrupt方法的作用以後，再回過頭來看的Java中這段程式碼，就很好理解了。由於前者先設定了一箇中斷標識為真實的，所以這個方法的返回值為真，故而不滿足而迴圈的判斷條件導致退出迴圈。Thread.currentThread().isInterrupted()isInterrupted()

這裡有必要再提一句，就是這個執行緒中斷標識有兩種方式復位，第一種是前面提到過的InterruptedException的;另一種是通過Thread.interrupted（）對當前執行緒的中斷標識進行復位。

推薦一個交流學習交流圈子：

相關推薦