Java调度线程池执行器对某些条件进行初始延迟对某些值进行检查

Question

问题：

我有一个任务，它必须在每个任务运行后以固定的延迟定期运行。另外，我有一个条件，在初始延迟或第一次执行应该发生在一个条件满足后。因此，执行器必须阻止调度任务，直到满足条件为止。

Java并发包为我们提供了ScheduledThreadPoolExecutor，它具有初始延迟的选项。但在我的例子中，初始延迟是在某个条件或值改变为所需的条件或值之后。

我如何实现这个行为以及我应该使用什么executorservice或者我可以重写executorservice中的什么方法来实现上述行为。

我不想只在满足条件之后才开始创建ScheduledThreadPoolExecutor对象，原因是我们的应用程序中存在大量这样的定期调度任务，如果下一次添加了任何新任务，并且如果它们忘记在进行检查的代码部分中添加，那么它将被立即调度，而不进行任何条件检查。为了避免这种情况，我想要一个executor服务来为我处理它，下次任何使用这个executorservice的人都将在默认情况下免费获得这种行为。

感谢任何帮助。

谢谢你

Answer 1

我不认为您会找到现成的ExecutorService来处理您的用例。所以为什么不这样做呢？创建扩展ScheduledThreadPoolExecutor的自定义类，然后重写beforeExecute方法，然后编写代码检查首次执行（使用自定义标志检查是否首次执行），而对于其他调用，它将执行正常的可运行对象。类似于下面的代码：

import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class TestClass extends ScheduledThreadPoolExecutor {

public TestClass(int corePoolSize) {
    super(corePoolSize);
}

@Override
protected void beforeExecute(Thread t, Runnable r) {
    super.beforeExecute(t, r);
}

@Override
public ScheduledFuture<?> scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit) {
    return super.schedule(command, initialDelay, TimeUnit.MILLISECONDS);
}
}