为什么Java的scheduleWithFixedDelay使用Runnable而不是FutureTask <?>包装runnable?

Nat*_*ger 6 java concurrency scheduled-tasks

为什么Java的scheduleWithFixedDelay使用Runnable而不是FutureTask包装runnable?

使用两个不同的代码示例可以很容易地显示它:

ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
        executorService.scheduleWithFixedDelay(new FutureTask<Integer>(new Callable<Integer>() {

            @Override
            public Integer call() throws Exception {
                System.out.println("beep");
                return 1;
            }
        }), 1, 5, TimeUnit.SECONDS);
Run Code Online (Sandbox Code Playgroud)

生产:

但是应用程序没有退出,它似乎只是等待.

但:

ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();
    executorService.scheduleWithFixedDelay(new Runnable() {

        @Override
        public void run() {
            System.out.println("beep ");
        }
    }, 1, 5, TimeUnit.SECONDS);
Run Code Online (Sandbox Code Playgroud)

生产:

哔哔哔哔哔声

以5秒的间隔.

看起来这里发生了一些我无法确定的锁定.

And*_*yle 13

因为你有点滥用FutureTask.

根据Javadocs,FutureTask是"可取消的异步计算",但更通俗地说,它包含了Runnable/Callable的特定执行以提供异步性.Runnable直到我刚才检查时才实际意识到它已实现- run()"将此Future设置为其计算结果"的实现.

所以在你的第一个例子中发生的是你正在安排未来的任务,它的run方法在1秒后被调用,因此它计算计算的结果(即运行嵌入式Runnable).当这个方法退出时,FutureTask现在已经运行并且具有其具体结果 - 因此run()的未来调用是no-ops.

我认为这里的根本问题是直接安排FutureTask似乎没有意义,至少不是你在这里做的方式.如果你想要每五秒钟运行一些代码,那么你绝对应该采用第二种方法.FutureTask体现了(单个!)计算; 你没有理由要多次调用它,事实上它是专门缓存结果来防止这种情况.