6

我刚刚开始研究 Java 中的 Futures 和 ScheduledExecutorService，我想知道为什么我的 Callable 没有按我指定的时间表运行。在此示例代码中，可调用对象运行一次，但应用程序永远不会完成，任务也不会再次运行，这是我预期会发生的（我确定问题出在我的预期中）。

Runnables 工作正常；可调用对象似乎永远阻塞，但我不知道为什么......我错过了什么？

谢谢！

   public class ExecutorExample {

    /**
     * @param args
     * @throws ExecutionException 
     * @throws InterruptedException 
     */
    public static void main(String[] args) throws InterruptedException, ExecutionException {

        ScheduledExecutorService scheduler =  Executors.newScheduledThreadPool(5);

        FutureTask<ArrayList<String>> ft1 = new FutureTask<ArrayList<String>>(new Callable<ArrayList<String>>(){
            @Override
            public ArrayList<String> call() {
                ArrayList<String> stuff = new ArrayList<String>();
                for(int i = 0;i<10;i++){
                    String thing ="Adding " + i + " to result"; 
                    stuff.add(thing);
                    System.out.println(thing);

                }
                return stuff;
            }});

        scheduler.scheduleAtFixedRate(ft1, 0, 1, TimeUnit.SECONDS);

        System.out.println(ft1.get());
        System.out.println(ft1.isDone());

    }
}
4

1 回答 1

9

问题在于它FutureTask被使用了，正如它的类文档所说，“一旦计算完成，计算就不能重新启动或取消。”

在run方法FutureTask被调用一次后，后续调用立即返回，而不委托给任务的Callable实例。

只有 aRunnable可以用作重复任务，这不允许传回结果。相反，给Runnable任务一个回调，它可以在其run方法结束时调用，将任务每次执行的结果报告给其他线程中的侦听器。

于 2009-07-24T19:31:15.767 回答