将ListenableScheduledFuture转换为ListenableFuture < something other >

Question

我希望得到您对以下问题和解决方案(潜在)的反馈。

假设有一个可运行的任务，该任务对 CPU 使用情况进行采样并将其写入 CSV 文件。此任务不返回任何结果。这需要安排永久定期执行。如果用户取消任务，我们关闭文件编写器，用户可以下载CSV文件。

当您将这样的任务提交给ListeningScheduledExecutorService(如下所示)时，您将获得一个ListenableScheduledFuture，它表示任务的结果。

ListenableScheduledFuture<Void> future = (ListenableScheduledFuture<Void>) scheduledExecutorService
            .scheduleAtFixedRate(task, initialDelay, interval, timeUnit); 

我们注册了一个对未来的回调，这样当任务被取消时，CSV文件就可以下载了:也就是说，我们需要将ListenableScheduledFuture转换为ListenableScheduledFuture。

Function<Void, File> transformFunc = new Function<Void, File>()
{
    @Override
    public File apply(Void arg0)
    {
        return file;
    }
};

ListenableScheduledFuture<File> futureToListen = (ListenableScheduledFuture<File>) Futures.transform(future, transformFunc);

// register a callback to the ListenableScheduledFuture<File>
Futures.addCallback(futureToListen, callback, executorService);

注意：根据Guava API DOC1，取消futureToListen将导致我们的任务被取消。

问题:

>

因为任务结果无效，所以如上所示强制转换为ListenableschduledFuture是否有意义？

将返回void的任务的未来转换为某种类型的未来在语义上有意义吗？

有没有更好更优雅的解决方案？用Java8的CompletableFuture会不会更好？

Answer 1

< code>transform可能不会如您所愿。您提到取消< code>futureToListen将取消< code>future，这是事实。问题是储备也是如此:当< code>future被取消时，< code>futureToListen也会被取消。这意味着它永远不会计算结果。

要解决此问题，您有几个选择：

1. 如果您不在乎能否取消未来，请将futureToListen。然后让取消future的人也拨打futureToListen.set（file）
2. 如果您确实想取消future，那么请将futureToListen，它（a）公开0.05（）

还有其他可能的聪明的解决方案，包括每当< code>future不成功地完成时触发工作，但是我不确定我是否推荐这样做。我个人对使用“< code>Future被取消”作为“工作成功完成”的信号感到有点紧张这是因为< code>Future也可能会被取消，例如，执行程序关闭。(另一个原因是:你需要小心区分“执行过程中抛出异常”和“被取消”)由于这个原因，我建议的解决方案设置为直接调用< code>set()，而不是触发未来的任何取消。