java - 预定的执行者服务。如何在两个单独的服务中经过一段时间后运行两个任务

Question

我正在尝试为我的应用程序实现连续运行的后台任务。为此，我使用了 ScheduledExecutorService 类。我有 2 个服务 Service A 和 Service B 都有一个在一定时间间隔后一直运行的任务。为此，我在 Service A 和 Service B

中使用了以下内容

这是两个服务类中通用的代码。

Runnable postNotificationRunnable = new Runnable() {
            @Override
            public void run() {
            // statements here}
ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1);
    scheduledExecutorService.scheduleAtFixedRate(postNotificationRunnable, 0, 1000, TimeUnit.SECONDS);

现在的问题是，当我运行应用程序时，两个服务都会启动，但只有 Service A 的 ScheduledExecutorService 运行，其他服务不运行。我做错了什么？P.S 我是第一次使用 ScheduledExecutorService。

Answer 1

ScheduledExecutorService 将等待您的任务完成，前提是任务花费的时间超过您指定的速率(在您的情况下为 1000 秒)。看看各自的Javadoc :

[...] If any execution of this task takes longer than its period, then subsequent executions may start late, but will not concurrently execute.

由于您的服务似乎表现得像守护进程(因此保持运行直到应用程序关闭)，您可以这样做:

ScheduledExecutorService scheduler = Executors.newSingleThreadScheduledExecutor();
ExecutorService pool = Executors.newCachedThreadPool();

scheduler.scheduleAtFixedRate(new Runnable() {
    @Override
    public void run() {
        pool.execute(postNotificationRunnable);
    }
}, 0L, 1000L, TimeUnit.SECONDS);

只需将服务的实际执行委托(delegate)给一个单独的池，该池不会影响调度程序。