Scheduler 類

Scheduler 類是排程類的抽象類，其中定義了很多關鍵方法，比如 submit 方法等，並且是一個執行緒類，一直執行在主程序或者獨立 JVM 程序。

RemoteScheduler 類

RemoteScheduler 類是執行在主程序的排程類，支援併發操作，實現的方式就是之前說過的將 Job 封裝成 RemoteScheduler.JobRunner 類，RemoteScheduler 中維護兩個佇列，queue 用於儲存所有的需要執行的 Job，running 用於儲存正在執行的 Job，由於該類在主程序，所有同一時間可能會有多個直譯器 JVM 中的 Job 正在執行，所以 running 是一個佇列，在 FIFOScheduler 中，該屬性其實就是一個物件，因為先進先出排程同一時間只能有一個正在執行的 Job 類的物件：

List<Job> queue = new LinkedList<>();
List<Job> running = new LinkedList<>();

該執行緒中 run 方法流程如下：
首先當正在執行的 Job 總數大於閾值或者任務 queue 是空的時候，等待 0.5s ，其他情況下從佇列中取出一個 Job 並加入到 running 佇列中：

synchronized (queue) {
  if (running.size() >= maxConcurrency || queue.isEmpty() == true
 
) {
    try {
      queue.wait(500);
    } catch (InterruptedException e) {
      logger.error("Exception in RemoteScheduler while run queue.wait", e);
    }
    continue;
  }

  job = queue.remove(0);
  running.add(job);
}

然後對 job 封裝成 JobRunner 的物件 jobRunner，封裝原因在 Job 相關類中說過，封裝之後直接將 jobRunner 直接扔到 Java 自帶的執行緒池執行：

Scheduler scheduler = this;
JobRunner jobRunner = new JobRunner(scheduler, job);
executor.execute(jobRunner);

一旦該 job 被提交到直譯器 JVM，則進行下一次迴圈，重複以上步驟。

ParallelScheduler 類

這個類是執行在直譯器 JVM 中的排程類，支援併發 Job，實現的方式是 Job 封裝成 ParallelScheduler.JobRunner 類，程式碼基本和 RemoteScheduler 相似，這裡不再贅述。

FIFOScheduler 類

這個類也是執行在直譯器 JVM 中的排程類，只不過不支援併發，由於比較簡單，這裡不再贅述。

SchedulerListener 類

SchedulerListener 介面中定義了兩個方法，jobStarted 和 jobFinished 方法，它唯一的實現類是 SchedulerFactory 類，實現類中這兩個方法都是向日志中輸出一句話。

SchedulerFactory 類

這個類是建立各種排程的工廠類，呼叫 reateOrGetXXXScheduler 的時候，返回的已經是在執行的執行緒了：

public Scheduler createOrGetFIFOScheduler(String name) {
  synchronized (schedulers) {
    if (schedulers.containsKey(name) == false) {
      Scheduler s = new FIFOScheduler(name, executor, this);
      schedulers.put(name, s);
      executor.execute(s);
    }
    return schedulers.get(name);
  }
}

Java 執行緒池參考資料