code: private void computeNextLoad() {
          Long processId = getMinTransformedProcessId();
          if (processId != null) {
              replys.get(StageType.LOAD).offer(processId);
          }
      }
docs: 计算下一个load的processId