Java如何设置超时阈值终止运行超时的doSomething方法

你原有代码不生效的核心原因是doSomething()是同步阻塞执行的，一旦调用该方法，当前线程会一直等待方法执行完成才会进入下一行的时间判断，相当于你等500ms方法跑完才去看有没有超300ms，自然没有超时终止的效果，额外加的while循环反而会反复调用doSomething()，和需求完全不符。

在Java中可以通过多线程机制实现该需求，常见实现方案如下： #

方案1：线程池+Future带超时获取（JDK 1.5+通用方案） #

核心思路是把doSomething()放到独立线程执行，主线程只等待指定时长，超时就主动取消任务执行，代码示例：

import java.util.concurrent.*;

public class TimeoutDemo {
    // 初始化线程池，根据业务场景调整线程池配置即可
    private static final ExecutorService executor = Executors.newSingleThreadExecutor();

    public static void main(String[] args) {
        int result;
        Future<Integer> future = executor.submit(() -> doSomething());
        try {
            // 等待300ms获取结果，超时直接抛出TimeoutException
            result = future.get(300, TimeUnit.MILLISECONDS);
            System.out.println("执行成功，结果：" + result);
        } catch (TimeoutException e) {
            // 超时后主动中断执行任务的线程
            future.cancel(true);
            System.out.println("方法执行超时，已终止");
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        } finally {
            // 线程池不用时记得关闭，业务如果长期使用可以复用线程池不用每次shutdown
            executor.shutdown();
        }
    }

    private static int doSomething() {
        // 模拟500ms耗时逻辑
        try {
            Thread.sleep(500);
        } catch (InterruptedException e) {
            // 收到中断信号后提前结束执行
            Thread.currentThread().interrupt();
            throw new RuntimeException("任务被中断");
        }
        return 0;
    }
}

注意事项：

• 如果doSomething()内部没有响应中断的逻辑（比如没有调用sleep/wait等可中断方法，也没有主动检查Thread.currentThread().isInterrupted()中断标志），那么即使调用future.cancel(true)也只是主线程放弃等待结果，后台执行doSomething()的线程还是会继续运行直到结束，不会真的被终止，这种场景需要你自行在doSomething()的耗时逻辑里添加中断检查。

方案2：CompletableFuture实现（JDK 9+ 简洁方案） #

JDK9之后CompletableFuture新增了orTimeout方法，代码更简洁：

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

public class TimeoutDemo2 {
    public static void main(String[] args) {
        CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> doSomething())
                .orTimeout(300, TimeUnit.MILLISECONDS);
        try {
            int result = future.get();
            System.out.println("执行成功，结果：" + result);
        } catch (TimeoutException e) {
            System.out.println("方法执行超时，已终止");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private static int doSomething() {
        // 实现和方案1一致，需要支持中断逻辑
        try {
            Thread.sleep(500);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            throw new RuntimeException("任务被中断");
        }
        return 0;
    }
}

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