嘿，我来帮你搞定这个需求～你现在的代码只是让Runnable立即执行，但没有超时终止的逻辑。要实现20秒后自动取消未完成的任务，我们可以借助Future跟踪任务状态，再配合延迟执行的取消任务来实现，下面给你详细说明：

核心思路 #

• 用ScheduledExecutorService提交你的任务，拿到Future对象——它就像任务的“遥控器”，能用来取消任务
• 再用同一个执行器调度一个延迟20秒的任务，这个任务的唯一作用就是调用Future.cancel(true)，中断并取消原任务
• 你的Runnable必须响应线程中断，这样被取消时才能及时停下，不然可能会一直跑下去

完整代码示例 #

// 先定义你的Runnable，记得处理中断逻辑
static class MyRunnable implements Runnable {
    private final Helper helper;

    MyRunnable(Helper helper) {
        this.helper = helper;
    }

    @Override
    public void run() {
        try {
            // 这里替换成你的实际业务逻辑，模拟一个耗时任务
            for (int i = 0; i < 100; i++) {
                // 每次循环都检查线程是否被中断，是的话立刻退出
                if (Thread.currentThread().isInterrupted()) {
                    System.out.println("任务被中断，提前终止");
                    return;
                }
                // 模拟耗时操作，比如网络请求、文件处理
                Thread.sleep(200);
                helper.updateProgress(i);
            }
        } catch (InterruptedException e) {
            // 像sleep这种阻塞方法被中断时会抛这个异常，直接退出就行
            System.out.println("任务超时被中断，终止执行");
            Thread.currentThread().interrupt(); // 保留中断标记，方便上层逻辑处理
        }
    }
}

// 启动任务并设置超时取消的逻辑
public void startTimeoutTask() {
    // 创建单线程调度执行器（如果是多次使用，建议复用这个实例，别每次都new）
    ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();

    // 提交任务，拿到控制用的Future
    Future<?> taskFuture = executor.submit(new MyRunnable(new Helper()));

    // 调度一个20秒后执行的取消任务
    executor.schedule(() -> {
        // 先判断任务有没有完成，没完成就取消
        if (!taskFuture.isDone()) {
            boolean cancelSuccess = taskFuture.cancel(true);
            System.out.println("任务超时，尝试取消：" + (cancelSuccess ? "成功" : "失败"));
        }
        // 用完执行器记得关闭，避免线程泄漏
        executor.shutdown();
    }, 20, TimeUnit.SECONDS);
}

// 示例用的Helper类，替换成你自己的业务类就行
static class Helper {
    void updateProgress(int progress) {
        System.out.println("任务执行进度：" + progress + "%");
    }
}

几个关键注意点 #

• 必须响应中断：如果你的任务里不处理中断，就算调用了cancel(true)，任务可能还是会继续执行。所以要么在循环里检查Thread.currentThread().isInterrupted()，要么处理InterruptedException。
• 关闭执行器：用完ScheduledExecutorService一定要调用shutdown()，不然会有线程一直驻留，造成内存泄漏。如果需要等所有任务都结束，可以用shutdown()加awaitTermination()。
• cancel参数说明：future.cancel(true)里的true表示中断正在运行的线程，如果你的任务不需要强制中断（比如只是想标记任务为取消状态，让任务自己判断停止），可以传false，但大部分耗时任务建议传true来强制终止。

另外，还有个更简洁的写法，用ExecutorService.invokeAll()，不过需要把任务包装成Callable，示例如下：

public void startTaskWithInvokeAll() throws InterruptedException {
    ExecutorService executor = Executors.newSingleThreadExecutor();
    // 把Runnable包装成Callable
    List<Callable<Void>> tasks = Collections.singletonList(() -> {
        new MyRunnable(new Helper()).run();
        return null;
    });

    // 等待任务完成，超时时间设为20秒，超时自动中断任务
    executor.invokeAll(tasks, 20, TimeUnit.SECONDS);
    executor.shutdown();
}

这种方式底层逻辑和之前的一样，只是封装得更简洁，看你习惯哪种写法啦～

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