使用OkHttpClient与Java Future调用task.cancel时抛出InterruptedIOException的问题排查

首先，咱们先把这个异常的本质说清楚：当你调用task.cancel(true)时，ScheduledExecutorService会中断正在执行该任务的线程，而OkHttp的IO操作（尤其是你这里用到的HTTP/2写入流程，从堆栈信息能看出来）会响应线程中断，抛出InterruptedIOException——这其实是OkHttp正常处理中断的表现，不是Bug，而是需要你正确应对的预期场景。

排查思路 #

• 确认cancel方法的参数：你调用task.cancel(...)时，如果传入的是true，就会触发线程中断；如果是false，只会取消后续的任务调度，当前正在运行的请求会继续完成。先核对你传入的参数是不是符合自己的需求。
• 分析异常触发时机：从堆栈信息看，异常发生在Http2Writer的写入阶段，说明你取消任务时，OkHttp正处于和服务器建立HTTP/2连接、发送请求头的IO操作中，这时候线程被中断，IO操作自然会抛出中断异常。
• 检查现有异常处理逻辑：你的代码已经捕获了IOException（InterruptedIOException是它的子类），所以这个异常不会导致程序崩溃，但你需要确认是否需要在捕获后做额外的资源清理工作。

解决方案 #

1. 根据需求选择合适的cancel参数 #

• 如果希望立即终止当前正在运行的请求，同时取消后续调度：继续用task.cancel(true)，但要在异常处理中补充资源清理。比如在genericMonitor方法中保存OkHttp的Call实例，捕获到InterruptedIOException时主动取消请求，释放底层连接资源：

// 在genericMonitor中保存Call实例
RealCall call = (RealCall) okHttpClient.newCall(request);
try (Response response = call.execute()) {
    // 处理响应逻辑
} catch (InterruptedIOException e) {
    call.cancel(); // 主动终止请求，释放资源
    logger.info("爬虫任务被中断，已释放相关资源", e);
} catch (IOException e) {
    logger.error("爬虫任务执行出错", e);
}

• 如果希望当前请求完成后再停止调度：调用task.cancel(false)，这样正在运行的爬虫请求会正常完成，之后ScheduledExecutorService不会再调度下一次任务。

2. 优化任务管理与异常处理 #

• 任务取消后，记得从tasks集合中移除对应的ScheduledFuture，避免内存泄漏：

boolean cancelled = task.cancel(true);
if (cancelled) {
    tasks.remove(link);
}

• 区分处理中断异常：因为这是预期的任务取消行为，不是错误，所以可以把它的日志级别设为INFO，避免和真正的错误日志混淆：

try {
    genericMonitor(percent, url, idSupplier, callback);
} catch (InterruptedIOException e) {
    logger.info("爬虫任务已被中断（用户触发任务取消）", e);
} catch (IOException e) {
    logger.error("爬虫任务执行过程中出现错误", e);
}

3. 提前检查线程中断状态 #

在genericMonitor方法的开头，先检查当前线程是否被中断，如果已经中断，直接返回，避免执行不必要的操作：

public void genericMonitor(...) throws IOException {
    if (Thread.currentThread().isInterrupted()) {
        logger.info("线程已中断，跳过本次爬虫执行");
        return;
    }
    // 后续的OkHttp请求逻辑
}

这样调整后，你就能优雅地管理爬虫任务的取消，同时正确应对OkHttp的中断异常啦。

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