Future.get(timeout) 不中断运行中任务，因超时仅控制等待而非终止执行；真正中断需任务主动响应中断信号，如检查Thread.isInterrupted()或捕获InterruptedException。
Future.get(timeout) 为什么有时不中断正在运行的任务
调用 future.get(3, TimeUnit.SECONDS) 超时后抛出 TimeoutException，但任务本身可能仍在后台线程中继续执行——这是最常见的误解。因为 Future 的超时控制只作用于「等待结果」这个动作，不是对任务执行体的强制终止。
真正中断任务，必须依赖任务内部响应中断信号（即检查 Thread.interrupted() 或捕获 InterruptedException），否则 future.cancel(true) 也无效。
- 任务是 CPU 密集型且没做任何阻塞/中断检查 →
cancel(true)不起作用 - 任务在
Thread.sleep()、BlockingQueue.take()、Object.wait()等可中断方法中阻塞 →cancel(true)会触发InterruptedException - 使用
Executors.newCachedThreadPool()时，线程复用可能导致中断状态被忽略，建议用Thread.currentThread().isInterrupted()显式检查
如何让 Future.cancel(true) 真正生效
关键不在调用 cancel(true)，而在任务逻辑是否尊重中断。下面是一个典型可中断任务写法：
Callabletask = () -> { for (int i = 0; i < 1000; i++) { if (Thread.currentThread().isInterrupted()) { throw new InterruptedException("Task interrupted"); } // 模拟工作 Thread.sleep(10); } return "done"; }; Future future = executor.submit(task); try { String result = future.get(100, TimeUnit.MILLISECONDS); } catch (TimeoutException e) { future.cancel(true); // 发送中断信号 System.out.println("Task cancelled: " + future.isCancelled()); }
注意：不要只依赖 catch (InterruptedException)，因为 sleep 被中断后会清空中断状态；循环中必须持续检查 isInterrupted()。
立即学习“Java免费学习笔记（深入）”；
CompletableFuture 有没有更简洁的超时方案
CompletableFuture 本身不提供原生超时接口，但可以用 orTimeout()（Java 9+）或组合 completeOnTimeout() + whenComplete() 实现类似效果，不过要注意它们只是「超时后返回默认值」，不会中断原始任务。
-
orTimeout(1, TimeUnit.SECONDS)：超时后以ExecutionException包装TimeoutException完成，但原始任务照跑 - 若需中断，仍要手动保存
Future引用，在超时回调里调用cancel(true) - 推荐组合写法：
CompletableFuture.supplyAsync(..., executor).orTimeout(1, SECONDS).exceptionally(e -> { if (e instanceof TimeoutException) future.cancel(true); return null; })
ExecutorService.shutdownNow() 对正在运行任务的影响
调用 executor.shutdownNow() 会尝试中断所有正在执行和等待的任务，但它只对响应中断的任务有效；对忽略中断的无限循环任务无能为力。
常见误用场景：
- 把
shutdownNow()当作「强制杀死所有任务」的银弹 → 实际只是发中断信号 - 未配合
awaitTermination()判断是否真结束了 → 返回false表示仍有活跃线程 - 在 Web 应用中直接 shutdown 全局线程池，导致后续请求无可用线程 → 应该按业务粒度管理生命周期
真正可靠的超时控制，永远建立在任务自身可协作中断的基础上，没有捷径。别指望框架替你“杀掉”一个死循环。
