时间戳

首页 > 解决方案 > Java ScheduledFuture 不等待任务完成

java - Java ScheduledFuture 不等待任务完成

问题描述

我有问题。我正在使用以下代码：

ScheduledExecutorService tradingPool = Executors.newScheduledThreadPool(1);
Runnable runTradingTask = () -> {
    new TradingDriver().run();
};
ScheduledFuture<?> scheduledTradingFuture = tradingPool.scheduleAtFixedRate(runTradingTask, 0, 1, TimeUnit.SECONDS);

在我的TradingDriver.run()我有一些 SQL 语句，所以这需要一些时间，大约 1.5 秒，但我注意到下一次运行已经开始。为了检查我的想法是否正确，我在函数的端点打印了“Started”和“Ended”。这是我的结果：

Started
Started
Ended
Started
Ended
Started
Ended
Started

如您所见，它打印 2x “Started”，这意味着在第一次运行未完成时开始另一次运行。现在我看到了这篇文章：ScheduledExecutorService 等待任务完成，但我可以看到 ScheduledFuture 没有等待完成。

如何TradingDriver.run()在两次执行之间连续运行 1 秒？

标签： java

解决方案

使用 scheduleWithFixedDelay 而不是 scheduleAtFixedRate

推荐阅读