如何编写符合规范的可中断线程代码？

你提到的重复检查中断标志的写法确实不够简洁，这并不是唯一的实现方式，以下是几种更符合编码规范的方案：

1. 封装中断检查为工具方法 #

把重复的中断检查逻辑抽成独立方法，减少代码冗余，符合DRY（Don't Repeat Yourself）原则：

public class ThreadUtils {
    public static void checkInterrupted() throws InterruptedException {
        if (Thread.interrupted()) {
            throw new InterruptedException();
        }
    }
}

// 使用示例
void interruptibleFunction() throws InterruptedException {
    doSmth();
    ThreadUtils.checkInterrupted();
    
    doSmth();
    ThreadUtils.checkInterrupted();
    
    doSmth();
    ThreadUtils.checkInterrupted();
}

2. 让耗时方法doSmth()自身支持中断 #

如果doSmth()是你可控的方法，直接在其内部添加中断检查，从根源上简化调用方代码：

• 若doSmth()包含Thread.sleep()、Object.wait()、BlockingQueue.take()等原生可中断阻塞方法，这些方法会自动响应中断并抛出InterruptedException，无需额外手动检查。
• 若doSmth()是纯计算型耗时操作，可在计算循环中插入中断检查：

void doSmth() throws InterruptedException {
    for (int i = 0; i < largeCalculationCount; i++) {
        // 核心计算逻辑
        ThreadUtils.checkInterrupted(); // 每轮循环插入中断检查
    }
}

// 调用方只需统一处理异常
void interruptibleFunction() throws InterruptedException {
    doSmth();
    doSmth();
    doSmth();
}

3. 使用ExecutorService+Future管理任务（推荐） #

现代Java并发编程更推荐用ExecutorService替代直接操作Thread，通过Future的cancel(true)方法可便捷中断任务，框架会自动处理线程生命周期：

ExecutorService executor = Executors.newSingleThreadExecutor();
Future<?> future = executor.submit(() -> {
    try {
        doSmth();
        doSmth();
        doSmth();
    } catch (InterruptedException e) {
        // 执行中断后的资源清理逻辑
        Thread.currentThread().interrupt(); // 恢复中断标志，让上层代码感知
    }
});

// 需要中断时调用
future.cancel(true);
executor.shutdown();

这种方式无需手动管理中断检查，同时提供更规范的任务调度和资源管控能力。

额外注意 #

• 若doSmth()是第三方不可修改的不可中断阻塞操作（如传统IO），可考虑用InterruptibleChannel替代传统IO类，或在独立线程中执行并通过关闭资源终止任务。
• 捕获InterruptedException后，建议恢复中断标志（Thread.currentThread().interrupt()），确保上层代码能感知到中断事件。

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