Spring Boot API调用Thread.sleep()触发中断信号的问题解决

我用Spring Boot构建服务，写了一个扫描数据库更新状态的API，流程是：

1. 扫描数据库并更新状态
2. 若未查询到数据，休眠5分钟后回到步骤1

但执行Thread.sleep(300000)时会抛出InterruptedException，导致流程终止。请问如何避免该中断信号，或在异常抛出后恢复线程？

原代码： #

public void update(String product, int status, List<String> type, int maxRetry, int size, double hours) { //NOSONAR

  do {
    try {
      list = repository.getList(status, product, type, hours, size);
      for (Data data: list) {
        // update data
      }
      entityManager.clear();
      if (list.isEmpty()) {
        // sleep 5 minutes
        Thread.sleep(300000);
      }
    } catch (InterruptedException e) { 
      log.error(e.getMessage(), e);
      Thread.currentThread().interrupt();
      break;
    }
  } while (obConfigService.isInWorkingHours());
}

问题根源 #

InterruptedException是线程收到中断信号时抛出的协作式标记，常见于服务停机、线程池销毁或者手动中断场景，不是错误，但你当前代码捕获异常后直接break，导致循环终止，流程停止。

处理方案 #

方案1：调整异常逻辑，恢复流程

如果需要在工作时间内持续运行，不要直接中断循环，而是保留中断标记并继续执行：

public void update(String product, int status, List<String> type, int maxRetry, int size, double hours) { //NOSONAR
    do {
        try {
            list = repository.getList(status, product, type, hours, size);
            for (Data data: list) {
                // update data
            }
            entityManager.clear();
            if (list.isEmpty()) {
                Thread.sleep(300000);
            }
        } catch (InterruptedException e) { 
            log.warn("休眠被中断，将继续执行扫描任务", e);
            // 保留中断标记，让后续逻辑感知到中断状态
            Thread.currentThread().interrupt();
            // 回到循环开头，检查是否仍在工作时间且未被强制中断
            continue;
        }
    } while (obConfigService.isInWorkingHours() && !Thread.currentThread().isInterrupted());
}

修改while条件，加入!Thread.currentThread().isInterrupted()，确保线程收到强制中断信号时能优雅退出。

方案2：用定时任务替代Thread.sleep（更推荐）

Spring环境下，手动用Thread.sleep不是最佳实践，建议用ScheduledExecutorService或Spring的@Scheduled来实现延迟，避免手动处理线程中断：

private final ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();

public void startUpdateTask(String product, int status, List<String> type, int maxRetry, int size, double hours) { //NOSONAR
    Runnable scanTask = () -> {
        if (!obConfigService.isInWorkingHours() || Thread.currentThread().isInterrupted()) {
            scheduler.shutdown();
            return;
        }
        
        list = repository.getList(status, product, type, hours, size);
        for (Data data: list) {
            // update data
        }
        entityManager.clear();
        
        if (list.isEmpty()) {
            // 延迟5分钟后再次执行
            scheduler.schedule(scanTask, 5, TimeUnit.MINUTES);
        } else {
            // 有数据，立即执行下一次扫描
            scanTask.run();
        }
    };
    scanTask.run();
}

这种方式由线程池管理生命周期，中断处理更规范，也符合Spring生态的最佳实践。

关键注意点

• 不要忽略InterruptedException，捕获后要么恢复中断标记，要么优雅退出，这是线程协作的核心机制。
• 原代码的break是流程终止的直接原因，调整为continue并补充中断状态判断，就能恢复循环。
• 如果是Spring Boot启动时的后台任务，更推荐使用@Async配合@Scheduled注解，无需手动管理线程。

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