Future<Result> f = pool.submit(task);
try { f.get(5, TimeUnit.SECONDS); }
catch (TimeoutException e) { f.cancel(true); }
导出任务前一天下午提交,第二天早上还在 RUNNABLE,jstack 里线程停在 FutureTask.awaitDone,调用方是 future.get() 没有参数。这类现象通常不是突然出现的,往前翻半天日志能看到苗头。
追下去是这么回事:无参 get 会一直等下去,任务那边卡在下游读取,永远不会 complete。线程被占住,取消信号也没人发。
这次卡住的地方就在「future.get 无超时」这一环,单独把它拎出来验证,别和其他改动混在同一次发布里。监控和日志的时间要对上,时区不一致会多绕很大一圈。
临时改动用注释写上日期和原因,过两周自己都记不清为什么这么写。动手前把原文件复制一份带时间戳,出问题立刻换回去,比现场分析快得多。
处理上按这个顺序:所有 get 带上超时时间 按业务上限给 3 到 5 秒;超时后调 cancel(true) 任务里要响应中断;把超时当成失败处理 记录下游和耗时;批量提交时统计超时次数 超过阈值报警。
确认没问题再收工,慢任务在 5 秒后被取消,线程回到空闲,第二天没有堆积的 RUNNABLE。
