Java ScheduledFuture调度问题：需在limit=5时终止调度器

嘿，我看出来你的代码为啥一直返回10了，核心问题有两个：

• 调度任务只执行一次：你用的schedule()方法是一次性的，任务跑完一次就结束了，limit只会变成1，永远到不了5，所以每次都返回testNum也就是10。
• Future结果获取逻辑完全错了：ScheduledFuture.get()只会拿到任务第一次执行的结果，之后你再怎么调用它，返回的还是同一个值。而且你的while循环会一直阻塞在get()这里（因为任务只跑一次），无限打印10，根本触发不了退出条件。

针对你的需求——每次执行任务、当limit等于5时停止调度器，我给你改好了代码，还加了详细说明：

修正后的完整代码 #

import java.util.concurrent.*;

public class ScheduledTaskDemo {
    static int limit = 0;
    static final int testNum = 10;
    static ScheduledExecutorService scheduler;

    public static void main(String[] args) {
        scheduler = Executors.newScheduledThreadPool(5);
        
        // 改用周期性调度方法：初始延迟10秒，之后每1秒执行一次（间隔时间可以按需调整）
        scheduler.scheduleAtFixedRate(new ScheduledPrinter(), 10, 1, TimeUnit.SECONDS);

        // 让主线程等待调度器关闭，避免程序提前退出导致任务中断
        try {
            // 设置1分钟超时，防止无限等待（可根据实际情况调整）
            scheduler.awaitTermination(1, TimeUnit.MINUTES);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    private static class ScheduledPrinter implements Runnable {
        @Override
        public void run() {
            limit++;
            // 按照需求输出结果：limit到5时返回limit，否则返回testNum
            System.out.println(limit == 5 ? limit : testNum);
            
            if (limit == 5) {
                scheduler.shutdown();
                System.out.println("调度器已停止，因为limit达到设定值5");
            }
        }
    }
}

关键修改点解释 #

• 换成周期性调度：把schedule()换成scheduleAtFixedRate()，这个方法会重复执行任务，这样limit才能逐步递增到5。参数里的1是每次执行的间隔时间，你可以根据需要改成其他值。
• 任务类型改为Runnable：因为我们不需要通过Future来传递结果，直接在任务内部处理打印和停止逻辑更简单。如果确实需要返回结果给主线程，可以用FutureTask或者自定义回调，但这个需求里Runnable足够用了。
• 主线程等待逻辑：添加scheduler.awaitTermination()，不然主线程会直接结束，调度器也会跟着终止，任务还没执行到5次就停了。
• 结果输出逻辑修正：直接在任务内部打印每次的结果，当limit到5时关闭调度器，完美符合你的需求。

如果坚持要用Callable的话，也可以调整，但对于周期性任务来说，上面的方案是最简洁直观的。

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