原因
最近在完善公司的基礎發布平台的時候，使用到了一線程去做一些異步的事情，在開發環境和測試環境驗證沒有任何問題，但是在程序在生產運行一段時間后，發現沒有得到自己想要的結果，為此開始了漫長的排查bug的之路，因為用到了一些線程，但是實際又沒有對這些線程足夠的監控，所以在排查問題的時候也是歷經艱難險阻；
原始代碼
protected ScheduledExecutorService executorService = Executors.newScheduledThreadPool(2);
/**
* 同步應用的jenkins狀態
*/
public void threadASyncAppJenkinsStatus() {
executorService.scheduleAtFixedRate(() -> {
List<ArchitectureApp> architectureApps = architectureAppMapper.listArchitectureApp();
architectureApps.parallelStream().forEach(architectureApp -> syncJenkinsBuild(architectureApp.getName(), ArchitectureType.APP));
}, 0, 6, TimeUnit.SECONDS);
}
/**
* 同步組件的jenkins狀態
*/
public void syncComponentJenkinsStatus() {
executorService.scheduleAtFixedRate(() -> {
List<ArchitectureComponent> architectureComponents = architectureComponentMapper.listArchitectureComponent();
architectureComponents.parallelStream().forEach(architectureComponent -> syncJenkinsBuild(architectureComponent.getName(), ArchitectureType.COMPONENT));
}, 0, 6, TimeUnit.SECONDS);
}
這是其中一部分的代碼，做的事情很簡單，程序每隔6s就去輪詢組件和應用的狀態，然后后面我會通過websocket同步到前端頁面。這是一段很簡單的代碼，很難想象這段代碼可能出錯。但是事與願違，通過開發和測試環境的測試，在上到生產運行了兩天發現前端頁面的jenkins狀態並沒有同步。而通過查看日志，也沒法觀察問題出在哪，所以只能另尋他法；
ExecutorsMonitor線程監控類
以下是我們開發的一個線程池工具類，該工具類擴展ScheduledThreadPoolExecutor實現了線程池監控功能，能實時將線程池使用信息打印到日志中，方便我們進行問題排查、系統調優。具體代碼如下
@Slf4j
class ExecutorsMonitor extends ScheduledThreadPoolExecutor {
private ConcurrentHashMap<String, Date> startTimes;
private String poolName;
/**
* 調用父類的構造方法，並初始化HashMap和線程池名稱
*
* @param corePoolSize 線程池核心線程數
* @param poolName 線程池名稱
*/
public ExecutorsMonitor(int corePoolSize, String poolName) {
super(corePoolSize);
this.startTimes = new ConcurrentHashMap<>();
this.poolName = poolName;
}
/**
* 線程池延遲關閉時（等待線程池里的任務都執行完畢），統計線程池情況
*/
@Override
public void shutdown() {
super.shutdown();
}
/**
* 線程池立即關閉時，統計線程池情況
*/
@Override
public List<Runnable> shutdownNow() {
return super.shutdownNow();
}
/**
* 任務執行之前，記錄任務開始時間
*/
@Override
protected void beforeExecute(Thread t, Runnable r) {
startTimes.put(String.valueOf(r.hashCode()), new Date());
}
/**
* 任務執行之后，計算任務結束時間
*/
@Override
protected void afterExecute(Runnable r, Throwable t) {
Date startDate = startTimes.remove(String.valueOf(r.hashCode()));
Date finishDate = new Date();
long diff = finishDate.getTime() - startDate.getTime();
// 統計任務耗時、初始線程數、核心線程數、正在執行的任務數量、已完成任務數量、任務總數、隊列里緩存的任務數量、池中存在的最大線程數、最大允許的線程數、線程空閑時間、線程池是否關閉、線程池是否終止
log.info(String.format(this.poolName
+ "-pool-monitor: Duration: %d ms, PoolSize: %d, CorePoolSize: %d, Active: %d, Completed: %d, Task: %d, Queue: %d, LargestPoolSize: %d, MaximumPoolSize: %d, KeepAliveTime: %d, isShutdown: %s, isTerminated: %s",
diff, this.getPoolSize(), this.getCorePoolSize(), this.getActiveCount(), this.getCompletedTaskCount(), this.getTaskCount(),
this.getQueue().size(), this.getLargestPoolSize(), this.getMaximumPoolSize(), this.getKeepAliveTime(TimeUnit.MILLISECONDS),
this.isShutdown(), this.isTerminated()));
}
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize, String poolName) {
return new ExecutorsMonitor(corePoolSize, poolName);
}
}
后來在生產終於定位問題，發現線程內部后來停止，同時發現的還有報錯，通過查閱資料發現，原來線程發生異常后會退出，通過try catch很好的解決了這個問題