如何優雅的「打斷」你的線程?
最近看了點 psi-Probe的源代碼,在線程列表頁面,可以對頁面中各個進行線程管理,其中有這樣一個操作,見最左側藍色方框:
點擊每個線程對應的箭頭按鈕,會彈出下方的提示:
實際這上按鈕的操作,是要 「Kill」這個指定的線程。
順著鏈接,我們能看到,具體的實現是這個樣子:
- String threadName = ServletRequestUtils.getStringParameter(request, "thread", null);
- Thread thread = null;
- if (threadName != null) {
- thread = Utils.getThreadByName(threadName);
- }
- if (thread != null) {
- thread.stop();
- }
正如前面的彈窗提示,這里果然調用的是個危險操作:
- Thread.stop()
這里的 「stop」方法,和「resume」方法、「suspend」方法并稱 Thread 三少,因為線程安全問題,都已經被 @Deprecated 了。
官方文檔說的好:
Stopping a thread causes it to unlock all the monitors that it has locked |
當我們停止一個線程時,它會悄悄的把所持有的 monitor 鎖釋放了,此時,其他依賴鎖的線程可能就會搶到鎖執行。關鍵此時,當前 stop 的線程實際并沒有處理完所有先決條件,可能這個時候就產生了詭異的問題,加班的日子可能就悄悄來了。
那你說 「Stop 不讓用了,總得讓我們有辦法處理線程吧,哪怕通知他,打斷他一下,讓他停止」。
目前有以下幾種方式來實現。
異常
這點 Thread 也想到了,提供了一個「異常」來達到這個打斷的目的。這個異常在其他線程要打斷某個特定線程時執行,如果是符合條件,會拋出來。此時這個特定線程自行根據這次打斷來判斷后續是不是要再執行線程內的邏輯,還是直接跳出處理。
這個異常就是 InterruptedException。一般使用方式類似這樣
- try {
- Thread.sleep(backgroundProcessorDelay * 1000L);
- } catch (InterruptedException e) {
- // 具體在中斷通知后的操作
- }
- xxxThread.interrupt();
目前有以下方法能夠進行這種操作
- Thread.sleep
- Thread.join
- Object.wait
以wait方法為例,我們來看文檔里的描述
- * @throws InterruptedException if any thread interrupted the
- * current thread before or while the current thread
- * was waiting for a notification. The <i>interrupted
- * status</i> of the current thread is cleared when
- * this exception is thrown.
這里有一點信息: 「interrupted status」,這個是個狀態標識,在Thread類中,可以通過 isInterrupted來判斷當前線程是否被中斷。這個標識也可以用來作為一個退出線程執行的標識來直接使用。 但例外是阻塞方法在收到中斷方法調用后,這個標識會被清除重置,所以需要注意下。
我們在執行阻塞方法線程的interrupt方法時,此時并不能拿到這個標識。
另外,拿到異常時,需要關注,如果是類似于后臺循環執行的調度線程,在收到中斷異常時需要處理異常再 break 才能跳出,否則只是相當于一個空操作。
目前一些程序里用這種的倒不多,用下面這種的多一些。
退出標識
對于一些長駐線程,會在某些時候需要退出執行,這種情況下,常采用的操作類似這樣, 以Tomcat 的NioConnector 里的Acceptor為例:
- protected class Acceptor extends AbstractEndpoint.Acceptor {
- @Override
- public void run() {
- int errorDelay = 0;
- // Loop until we receive a shutdown command
- while (running) { // 標識1
- // Loop if endpoint is paused
- while (paused && running) { // 標識2
- state = AcceptorState.PAUSED;
- try {
- Thread.sleep(50);
- } catch (InterruptedException e) {
- // Ignore
- }
- }
- if (!running) {
- break;
- }
- ...
- }
用這種退出標識時,記得一定要聲明為 volatile ,類似這樣:
- /**
- * Running state of the endpoint.
- */
- protected volatile boolean running = false;
- /**
- * Will be set to true whenever the endpoint is paused.
- */
- protected volatile boolean paused = false;
否則因為多線程的可見性問題, 這個線程可能一直都不會退出。
目前在 Tomcat 使用中,無法在運行時直接操作 Connector ,所以一般情況這個 pause 標識可能沒法設置。但有幾種觸發的方式,一種是通過 JConsole 等工具連接到 MBeanServer 上,直接通過其MBean方法操作pause,來改變值,另一種是使用類似 psi-Probe(一款功能強大的Tomcat 管理監控工具)這種管理控制臺,之前我已經把可以操作 Connector 狀態的代碼提交給 github上(怎樣參與到全世界優秀的開源項目中?),commiter 已經合入。可以使用進行狀態改變觀察。
總體來說,如果處理sleep/wait等操作,擔心時間太長,可以通過 interrupt 來進行,對于駐留線程,可以通過退出標識來處理。
【本文為51CTO專欄作者“侯樹成”的原創稿件,轉載請通過作者微信公眾號『Tomcat那些事兒』獲取授權】