Callable需主动检测中断状态以实现优雅退出：在call()中定期调用Thread.interrupted()或isInterrupted()，阻塞操作捕获InterruptedException并清理资源，配合future.cancel(true)或shutdownNow()触发中断请求。
Java 中 Callable 本身不直接响应线程中断，但可以通过检查当前线程的中断状态（Thread.interrupted() 或 Thread.currentThread().isInterrupted()）并主动抛出 InterruptedException 或返回/清理后退出，来配合线程池（如 ThreadPoolExecutor）实现安全中断和优雅退出。
在 call() 中定期检测中断状态
这是最基础也最关键的一步。线程池调用 shutdownNow() 时，会尝试对正在执行的任务线程调用 interrupt()；但该操作仅设置中断标志，不会自动终止运行中的逻辑。因此你必须在耗时操作中主动检查：
- 使用
Thread.interrupted()（会清除中断状态）或Thread.currentThread().isInterrupted()（不修改状态）判断是否被中断 - 尤其在循环、I/O 等长耗时操作前后或内部检查，避免“假死”任务
- 若检测到中断，应尽快释放资源、清理中间状态，并选择抛出
InterruptedException或返回一个表示取消的结果（如null或自定义取消标记）
对阻塞操作做中断友好处理
很多 JDK 方法（如 Thread.sleep()、Object.wait()、BlockingQueue.take()、Future.get()）本身支持中断：它们在被中断时会立即抛出 InterruptedException 并清除中断标志。此时应：
- 捕获
InterruptedException，通常不吞掉它 —— 要么重新设置中断状态（Thread.currentThread().interrupt()），要么直接向上抛出（如果签名允许） - 在
catch块中完成必要清理（如关闭流、回滚事务、释放锁等） - 避免仅打印日志后静默忽略，否则线程池无法感知任务已响应中断
配合线程池的 shutdownNow 与 Future.cancel
单靠 Callable 内部检测还不够，需外部协同：
立即学习“Java免费学习笔记（深入）”；
- 提交任务后保留返回的
Future，调用future.cancel(true)可向执行线程发送中断信号 - 线程池层面调用
shutdownNow()会尝试中断所有正在执行的线程（包括Callable所在线程），此时你的call()必须能响应中断 - 注意：
cancel(true)和shutdownNow()不保证任务立即停止 —— 它们只是“请求”，最终行为取决于你的Callable是否真正检查并响应中断
示例：可中断的 Callable 实现
（关键逻辑已加注释）
public class InterruptibleTask implements Callable<String> {
@Override
public String call() throws Exception {
try {
for (int i = 0; i < 100; i++) {
// ✅ 每次循环前检查中断
if (Thread.interrupted()) {
System.out.println("任务被中断，准备退出");
return "CANCELLED";
}
// ✅ 模拟可能阻塞的操作（如网络请求、队列取值）
Thread.sleep(100); // sleep 会响应中断
}
return "SUCCESS";
} catch (InterruptedException e) {
// ✅ sleep 被中断：恢复中断状态并退出
Thread.currentThread().interrupt(); // 保持中断语义
return "INTERRUPTED";
}
}
} 
