Java 库类来处理“回调”的计划执行？

Question

我的程序有一个称为调度程序的组件，它允许其他组件注册它们想要回调的时间点。 这应该像 Unix cron 服务一样工作，即你告诉调度程序“在每个整点过十分钟通知我”。

我意识到 Java 中没有真正的回调。

这是我的方法，是否有一个图书馆已经做了这些事情？ 也请随意提出改进建议。

注册对调度程序的调用传递：

• 时间规范，包含小时、分钟、秒、年月、dom、dow，其中每一项可以未指定，意思是“每小时/每分钟等执行一次”。 （就像 crontabs 一样）
• 一个包含数据的对象，这些数据将告诉调用对象在收到调度程序通知时要做什么。 调度程序不处理这些数据，只是存储它并在收到通知时将其传回。
• 对调用对象的引用

启动时或新的注册请求后，调度程序从当前系统时间的日历对象开始，并检查数据库中是否有任何与该时间点匹配的条目。 如果有，则执行它们并重新开始该过程。 如果没有，Calendar 对象中的时间将增加一秒，并重新检查 entreis。 重复这一过程，直到有一个或多个条目匹配为止。 （离散事件模拟）

调度程序将记住该时间戳，每秒睡眠和唤醒以检查它是否已经存在。 如果它碰巧醒来并且时间已经过去，则它会重新开始，同样，如果时间已到并且作业已执行。

---

编辑：感谢您向我指出 Quartz。 然而，我正在寻找更小的东西。

Answer 1

查找 Quartz

Answer 2

如果您的对象确切地知道它们希望执行的各个时间点，那么您可以使用java.util.concurrent.ScheduledExecutorService。 然后他们简单地调用：

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);
long timeToExecute = ... //read from DB? use CronTrigger?
long delayToExecution = timeToExecute - System.currentTimeMillis();
scheduler.schedule(aRunnable, delayToExecution, TimeUnit.MILLISECONDS);

如果您希望调度程序本身处理“每 5 秒执行一次”之类的功能，或者您想要围绕错过执行或持久性进行复杂的行为，则只需使用 Quartz执行审计跟踪。

实际上，您可以简单地重用 Quartz 的 CronTrigger 类来获取“下一个执行时间”。 该类是完全独立的，不依赖于从 Quartz“上下文”中调用。 一旦您获得 Date 或 long 形式的下一个执行时间，您就可以像上面一样使用 Java ScheduledExecutorService

Answer 3

如果您的需求很简单，请考虑使用 java.util。计时器：

public class TimerDemo {

  public static void main(String[] args) {
    // non-daemon threads prevent termination of VM
    final boolean isDaemon = false;
    Timer timer = new Timer(isDaemon);

    final long threeSeconds = 3 * 1000;
    final long delay = 0;
    timer.schedule(new HelloTask(), delay, threeSeconds);

    Calendar calendar = Calendar.getInstance();
    calendar.add(Calendar.MINUTE, 1);
    Date oneMinuteFromNow = calendar.getTime();

    timer.schedule(new KillTask(timer), oneMinuteFromNow);
  }

  static class HelloTask extends TimerTask {
    @Override
    public void run() {
      System.out.println("Hello");
    }
  }

  static class KillTask extends TimerTask {

    private final Timer timer;

    public KillTask(Timer timer) {
      this.timer = timer;
    }

    @Override
    public void run() {
      System.out.println("Cancelling timer");
      timer.cancel();
    }
  }

}

正如所述，ExecutorService java.util.concurrent< /a> 如果您需要的话，可以提供更丰富的 API。

Answer 4

Quartz 是该领域中最强大且明显的强者，但还有一些替代方案可供探索。

Cron4j 是一个足够不错的库，比 Quartz 更轻量级。 它提供了很好的文档并且会做你想做的事。

可能更有趣的是，如果您想使用更适合 Java 并发库（特别是 Executors 和 ScheduledExecutors）的库，那么 HA-JDBC 有一个 CronExecutorService 接口，由其 CronThreadPoolExecutor 实现。 现在，有趣的是，它依赖于 Quartz（提供 CronExpression 类），但我发现两者一起工作比单独使用 Quartz 效果更好。 如果您不想要大量的依赖项，可以轻松地从 Quartz 和 HA-JDBC 中提取一些类来实现这一点。

由于您想要更小的东西（刚刚注意到您的编辑），请从 Quartz 获取 CronExpression 以及我上面提到的两个 HA-JDBC 类。 这样就可以了。

Answer 5

我强烈推荐 cron4j （已经提到过）而不是 Quartz，除非你绝对需要更多Quartz 的高级和复杂功能。 Cron4j 很好地专注于它应该做的事情，有不错的文档，并且不是一个厨房水槽解决方案。

Answer 6

通常推荐使用 Quartz 调度程序。

Answer 7

不敢相信 java.util.Timer 被选为答案。 石英确实是一个更好的选择。

与 java.util.Timer 相比，quartz 的一大优点是，使用quartz，作业可以存储在数据库中。 因此，一个 jvm 可以调度，而另一个 jvm 可以执行。 而且（显然）该请求在 jvm 重新启动后仍然存在。

Answer 8

可能更有趣的是，如果您想使用更适合 Java 并发库（特别是 Executors 和 ScheduledExecutors）的库，那么 HA-JDBC 有一个 CronExecutorService 接口，由其 CronThreadPoolExecutor 实现。 现在，有趣的是，它依赖于 Quartz（提供 CronExpression 类），但我发现两者一起工作比单独使用 Quartz 效果更好。 如果您不想要大量的依赖项，可以轻松地从 Quartz 和 HA-JDBC 中提取少量的类来实现这一点。

我只是想说，我尝试提取这些类，并且成功了！ 我需要这三个类：

• CronExpression (quartz)
• CronThreadPoolExecutor (ha-jdbc)
• DaemonThreadFactory (ha-jdbc)

我只需要做这些小调整：

• 从 CronThreadPoolExecutor 中删除记录器（它已创建但从未使用过）
• 将常量 YEAR_TO_GIVEUP_SCHEDULING_AT 从CronTrigger 到 CronExpression

我很高兴我没有陷入混乱的依赖关系中。 恭喜班级作者！

而且它一直运作得像冠军一样。