任务调度是如何实现的？

Question

我已经做了很多工作来从 Web 服务检索一些数据，但现在遇到了调度请求的问题，我不太确定从哪里开始。

我监听 jms 队列中的事件，收到事件后，我需要在一段时间后向 Web 服务发出请求。持续时间根据事件属性而变化。如果 Web 服务返回 false，我需要继续安排请求，直到它返回 true。

我正在考虑在收到事件或错误响应时在队列上创建查找请求，但这似乎并不理想 - 我会不断地消耗消息，检查时间以查看是否应该发出请求如果没有，则将其放回到队列中。

如果有人对如何解决此类问题有建议，我将非常感激。

Answer 1

首先，确保将事件按照需要执行的顺序保留在队列中。这将确保您只需要查看队列的头部即可了解何时应安排下一个事件。您可以为此使用 PriorityQueue。

用于处理事件的线程将从该队列中轮询项目并处理它们。让它查看头部项目并查看何时需要运行下一个事件。选择一个对象用作锁定对象，并让主线程对该对象调用 Object.wait(long)，并向该方法传递下一个事件需要运行之前的毫秒数。

如果有新线程进来，将其添加到队列中适当的位置。如果该项目位于队列的头部，则意味着线程需要更快地唤醒。在锁对象上调用Object.notifyAll()来唤醒处理线程。它将发现没有什么需要处理并返回睡眠状态适当的时间。

public class ProcessingQueue extends Thread {

  private PriorityQueue<Task> tasks;  

  private volatile boolean isRunning = true;

  public void addTask(Task t) {
    synchronized (this.tasks) {
      this.tasks.offer(t);
      // this call requires synchronization to this.tasks
      this.tasks.notifyAll();
    }
  }

  public void shutdown() {
    this.isRunning = false;
    synchronized (this.tasks) {
      this.notifyAll();
    }
  }

  public void run() {
    while (this.isRunning) {
      synchronized (this.tasks) {
        Task t = this.tasks.peek();
        // by default, if there are no tasks, this will wake every 60 seconds
        long millisToSleep = 60000;
        // getExecuteMillis() should return the time, in milliseconds, for execution
        if (t != null) millisToSleep = t.getExecuteMillis() - System.currentTimeMillis();
        if (millisToSleep > 0) {
          try {
            // this line requires synchronization to this.tasks
            // and the lock is removed while it waits
            this.tasks.wait(millisToSleep);
          } catch (InterruptedException e) {
          }
        }
        t = this.tasks.poll();
        if (t != null) {
          t.execute();
        }
      }
    }
  }
}

Answer 2

我同意使用 3-d party 库。我为此使用石英框架。
http://www.quartz-scheduler.org/

Answer 3

使用现有的 OSS 调度程序： http://java-source.net/open-source/job -scheduler

你总是可以自己推出，但我不推荐它。

调度程序的一个重要特性应该是它能够在重新启动/崩溃后幸存下来。

Answer 4

我决定使用 Spring 任务调度已在版本 3 中引入。它提供池化、基于时间瞬间和间隔的调度，如果需要更多自定义，它有一个 cron 选项。我没有深入研究 Quartz 可以实现的目标，但它也提供了与 Quartz 的集成。