Java線程阻塞排查

java

time: 2020-3-12

• • 1 線程排查
    • 1.1 jps找到進程PID
    • 1.2 top -Hp pid查看進程當前啟用的線程
    • 1.3 jstack -l pid > stack.txt
  • 2 線程池中使用Future中斷線程

記一次使用Future.get(timeout)過程中線程超時未中斷的經驗.

1 線程排查

首先是如何排查當前堵住的線程來源於哪部分代碼,我們這里使用jstack
比較完整的排查攻略:
https://juejin.im/post/5d6207c6f265da03b46bf933
https://blog.csdn.net/weiweicao0429/article/details/53185999

1.1 jps找到進程PID

jps

1.2 top -Hp pid查看進程當前啟用的線程

top -Hp pid

這里按快捷鍵shift+t可以占用時間比較長的線程倒序排出來.
這里可以看到有兩個線程正在跑,其中一個已經跑了13分鍾,具體TIME+代表的含義13:25.61代表
就是分鍾,秒,毫秒.

1.3 jstack -l pid > stack.txt

這里記錄一次jvm進程所有的線程信息,然后將剛才找到的阻塞線程的pid轉換成16進制.

printf %x pid

jvm中的線程號都是根據16進制編碼的,打開stack.txt,搜索這個16進制的線程號:
可以看到Future線程仍然在等待完成中,這和設置了超時退出不符,接下來查看Future線程中斷的正確用法.

2 線程池中使用Future中斷線程

enter description here

這里注意,任務超時就會拋出TimeoutException,我們捕獲到執行了fuutre.cancel(true)

根據源碼,這里確實是執行了線程中斷,那么有什么問題呢,到底是什么導致線程超時執行呢?

Thread.interrupt()方法不會中斷一個正在運行的線程。這一方法實際上完成的是，設置線程的中斷標示位，在線程受到阻塞的地方（如調用sleep、wait、join等地方）拋出一個異常InterruptedException，並且中斷狀態也將被清除，這樣線程就得以退出阻塞的狀態。
[引用自:https://www.cnblogs.com/onlywujun/p/3565082.html]

所以我們這次知道interrupt並不會立即中斷線程,而是異步中斷的方式,而此次超時不中斷執行是因為Future執行的task是一個耗時比較長的for循環:

這種情況下,顯然無法讓線程退出中斷,因為線程內部沒有對中斷做出反應.
這里有兩種方式:
1. 加入sleep方法,即可讓線程響應中斷.
2. 在循環體中判斷線程狀態.
方式一:

1. public void doMoreThings() throws InterruptedException { 
   

   ---

2. for (; ;) { 
   

   ---

3. Thread.sleep(10); 
   

   ---

4. System.out.println("Don't bother me"); 
   

   ---

5. } 
   

   ---

6.  
   

   ---

7. } 
   

   ---

方式二:

1. public void doMoreThings() throws InterruptedException { 
   

   ---

2. for ( ; ; ) { 
   

   ---

3. if (!Thread.currentThread().isInterrupted()) { 
   

   ---

4. System.out.println("Don't bother me"); 
   

   ---

5. }else { 
   

   ---

6. System.out.println(Thread.currentThread().getName()+",Just stop your work, Now!"); 
   

   ---

7. throw new InterruptedException(); 
   

   ---

8. } 
   

   ---

9. } 
   

   ---

10. } 
    

    ---

這樣就成功解決此次線程超時阻塞的問題了.