如何实施任务调度？

Question

我已经完成了一大堆工作来从Web服务中检索一些数据,但现在遇到了向它安排请求的问题,我不确定从哪里开始.

我收听事件的jms队列,收到事件后,我需要在一段时间后向Web服务发出请求.持续时间因事件属性而异.如果Web服务返回false,我需要继续计划请求,直到它返回true.

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

如果有人就如何实施这样的问题得到建议我真的很感激.

Answer 1

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

处理事件的线程将轮询该队列中的项目并处理它们.看看头部项目,看看下一个事件何时需要运行.选择一个对象用作锁定对象,并Object.wait(long)在该对象上调用主线程,将该方法传递给毫秒,直到需要运行下一个事件.

如果有新线程进入,请将其添加到适当位置的队列中.如果项目位于队列的头部,这意味着线程需要更快地唤醒.调用Object.notifyAll()lock对象来唤醒处理线程.它将看到没有任何东西可以处理并在适当的时间内重新入睡.

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();
        }
      }
    }
  }
}