wildfly-8 - 避免 ManagedScheduledExecutorService 中的重复任务

Question

我正在 wildfly 8.2 上开发 Java EE 7 应用程序，需要定期运行后台任务。我注入(inject)了一个执行程序服务并安排了一个任务，这部分工作正常:

@Resource
private ManagedScheduledExecutorService executorService;

...

executorService.scheduleWithFixedDelay(() -> {
  try {
    // do some stuff
  } catch (Throwable t) {
    log.error("Error", t);
  }
}, 0, 1, TimeUnit.MINUTES);

现在(实际上很好)的功能是在重新部署时保存计划任务，因此仍会在新部署中进行计划。

但是我如何检测任务是否已经安排好以避免多次安排它？

我尝试使用 ScheduledFuture 并取消 @PreDestroy 上的任务和@PrePassivate

reloadTreeFuture = executorService.scheduleWithFixedDelay(() -> {

...

@PreDestroy
@PrePassivate
protected void shutdown() {
  reloadTreeFuture.cancel(true);
}

只要相应的任务没有在触发取消的那一刻执行，这就可以正常工作。由于该任务运行时间长且运行频繁，因此在执行过程中命中它的可能性比较高。

如果在任务仍在执行时触发取消，则取消似乎什么都不做。它立即返回，方法 ScheduledFuture.isDone() 也返回 true 但从日志中我可以看到任务仍在后台执行，直到它到达需要注入(inject) Bean 的点，而注入(inject) Bean 不是由于取消部署过程可用。然后该过程以 org.jboss.msc.service.ServiceNotFoundException 结束 - 但仍在计划中。

  reloadTreeFuture.cancel(true);
  while (!reloadTreeFuture.isDone()) {
    Thread.sleep(200); // I know this is bad - it's just for testing
  }

如此基本的问题:我怎样才能确保任务不会被安排两次(或更多次)？

Answer 1

您可以记下每个任务的 ID，并在执行前检查它们。当然，这可能不是最佳解决方案，但它确实有效。