ScheduledExecutorService单线程创建非阻塞线程后polling线程终止问题排查

可能的原因分析 #

• 轮询任务本身抛出未捕获异常：单线程ScheduledExecutorService的任务如果抛出未检查异常，会直接终止后续所有调度，且默认不会输出异常日志。即便你在处理onProcessesEnded时新开了线程，轮询逻辑本身（比如调用第三方API、遍历Process集合）的异常仍会导致任务停摆。
• Process集合并发修改冲突：如果轮询线程遍历的集合是非线程安全类型（如ArrayList），新线程中对集合的修改（比如移除已结束Process）会触发ConcurrentModificationException，若该异常被上层代码吞掉，会导致轮询循环静默终止。
• 异步任务的异常未被监控：手动创建的新线程如果抛出异常，默认不会打印堆栈，若异常影响到共享资源状态，也可能间接导致轮询逻辑中断。

具体修复步骤 #

1. 给轮询任务加全局异常捕获
   在monitorProcesses方法最外层包裹try-catch(Throwable)，强制记录所有异常的完整堆栈，避免静默失败：

   private void monitorProcesses() {
       try {
           // 原轮询第三方API、检查Process状态的逻辑
           for (Process process : registeredProcesses) {
               if (isProcessEnded(process)) {
                   new Thread(() -> processService.onProcessesEnded(process)).start();
               }
           }
       } catch (Throwable t) {
           log.error("Monitor task crashed unexpectedly", t);
       }
   }
   

2. 确保Process集合的线程安全性
   替换非线程安全集合为CopyOnWriteArrayList，或在遍历/修改集合时加锁，避免并发修改异常：

   // 方案1：用并发安全集合
   private List<Process> registeredProcesses = new CopyOnWriteArrayList<>();
   
   // 方案2：加锁控制访问
   private final Object processLock = new Object();
   
   private void monitorProcesses() {
       try {
           synchronized(processLock) {
               for (Process process : registeredProcesses) {
                   // 检查状态逻辑
               }
           }
       } catch (Throwable t) {
           log.error("Monitor task failed", t);
       }
   }
   
   // 异步任务中修改集合时也要加锁
   new Thread(() -> {
       try {
           processService.onProcessesEnded(process);
           synchronized(processLock) {
               registeredProcesses.remove(process);
           }
       } catch (Throwable t) {
           log.error("Process end handler failed", t);
       }
   }).start();
   

3. 用线程池替代手动创建线程
   手动创建线程不仅浪费资源，还难以统一处理异常。提前初始化固定大小线程池，并配置未捕获异常处理器：

   private ExecutorService handlerPool = Executors.newFixedThreadPool(4);
   
   // 初始化时配置异常处理器
   handlerPool.setUncaughtExceptionHandler((thread, throwable) -> {
       log.error("Process end handler failed in thread {}", thread.getName(), throwable);
   });
   
   // 替换手动创建线程的代码
   handlerPool.submit(() -> processService.onProcessesEnded(process));
   

4. 检查第三方API调用的错误处理
   确保对第三方API的响应做完整校验，避免因API返回错误状态但未处理，导致后续逻辑中断：

   ApiStatusResponse response = thirdPartyApi.getProcessStatus(process.getId());
   if (!response.isSuccess()) {
       log.warn("Failed to fetch status for process {}: {}", process.getId(), response.getErrorMsg());
       continue; // 跳过该Process，继续处理剩余项
   }
   

内容的提问来源于stack exchange，提问作者deko