1. 背景
在?jstack?的內(nèi)容中可以看到以下的?MySQL Statement Cancellation Timer?守護(hù)線程, 在業(yè)務(wù)高峰期的時(shí)候會(huì)出現(xiàn)大量的這類(lèi)守護(hù)線程, 由此追溯該線程的生命周期過(guò)程;
"MySQL Statement Cancellation Timer" #20647 daemon prio=5 os_prio=0 tid=0x00007f2d087e9800 nid=0xfb83 in Object.wait() [0x00007f2b4b45a000]
? java.lang.Thread.State: TIMED_WAITING (on object monitor)
at java.lang.Object.wait(Native Method)
at java.util.TimerThread.mainLoop(Timer.java:552)
- locked <0x00000005da147038> (a java.util.TaskQueue)
at java.util.TimerThread.run(Timer.java:505)
? Locked ownable synchronizers:
- None
"MySQL Statement Cancellation Timer" #24138 daemon prio=5 os_prio=0 tid=0x00007f402802c800 nid=0x4cf64 in Object.wait() [0x00007f3e49453000]
? java.lang.Thread.State: WAITING (on object monitor)
at java.lang.Object.wait(Native Method)
at java.lang.Object.wait(Object.java:502)
at java.util.TimerThread.mainLoop(Timer.java:526)
- locked <0x00000005f606cc60> (a java.util.TaskQueue)
at java.util.TimerThread.run(Timer.java:505)
? Locked ownable synchronizers:
- None
2. TimerThread
java.util.TimerThread?是?Timer.java?文件里的一個(gè)內(nèi)部類(lèi), 主要負(fù)責(zé)?Timer?隊(duì)列任務(wù)的執(zhí)行和調(diào)度;
根據(jù)定位?Timer.java:526?位置的代碼, 當(dāng)前狀態(tài)?WAITING (on object monitor), 表示當(dāng)前的?timer?線程池為空, 正在等待新入駐;
根據(jù)定位?Timer.java:552?位置的代碼, 當(dāng)前狀態(tài)?TIMED_WAITING (on object monitor)?表示任務(wù)等待被激活;
3. getCancelTimer
根據(jù)線程名稱(chēng)?MySQL Statement Cancellation Timer?繼續(xù)追溯, 在?com.mysql.jdbc.ConnectionImpl#getCancelTimer?方法中找到該?TimerThread?的創(chuàng)建(cancelTimer):
4. getCancelTimer 的上游調(diào)用
主要是?mysql-connector-java-xxx.jar?中負(fù)責(zé) sql 查詢(xún)的?Statement
5. 創(chuàng)建 CancelTask timeoutTask
在?com.mysql.jdbc.StatementImpl#executeQuery?方法中可以發(fā)現(xiàn), 當(dāng)啟用?queryTimeout?且?timeoutInMillis!=0?時(shí), 在執(zhí)行 sql 的時(shí)候就會(huì)創(chuàng)建一個(gè)?CancelTask?的線程來(lái)控制超時(shí); (后面那個(gè)?versionMeetsMinimum?是個(gè)版本判斷可以先忽略)
然后在項(xiàng)目的?application.yml?中發(fā)現(xiàn)配置?mybatis.configuration.default-statement-timeout: 5, 所以?mybatis?在每次的數(shù)據(jù)庫(kù)查詢(xún)都會(huì)加上?queryTimeout, 且該配置對(duì)全局 SQL 生效, 包括?insert,?select,?update;
6. CancelTask 執(zhí)行過(guò)程
在?com.mysql.jdbc.StatementImpl.CancelTask#run?方法中, 會(huì)另起一個(gè)線程, 判斷如果啟用了?queryTimeoutKillsConnection?的配置時(shí), 會(huì)調(diào)用當(dāng)前?Statement?對(duì)應(yīng)的?Connection?里的?realClose?方法;
在?realClose?方法里發(fā)現(xiàn)會(huì)關(guān)閉?cancelTimer?線程;
7. Connection 關(guān)閉時(shí)
在?com.mysql.jdbc.ConnectionImpl#close?方法里也會(huì)發(fā)現(xiàn)有?realClose?方法的調(diào)用, 即在連接關(guān)閉時(shí)也會(huì)處理?cancelTimer?的釋放
8. 總結(jié) MySQL Statement Cancellation Timer 線程的流程
設(shè)置了?queryTimeout?會(huì)使?jdbc driver?在每次查詢(xún)數(shù)據(jù)庫(kù)時(shí)新建?CancelTask(timeoutTask對(duì)象) 線程來(lái)處理超時(shí), 并使用?CancelTimer(在?ConnectionImpl類(lèi)中) 來(lái)進(jìn)行調(diào)度;
如果?SQL?查詢(xún)超時(shí)了, 則會(huì)在?timeoutTask?的?run?方法里調(diào)用?com.mysql.jdbc.ConnectionImpl#realClose?來(lái)釋放?CancelTimer;
如果?Connection?正常關(guān)閉?close?時(shí), 也會(huì)調(diào)用?com.mysql.jdbc.ConnectionImpl#realClose?來(lái)釋放?CancelTimer;
