Method taskReadyToRunFuture

bolt/exec/Task.cpp:3137–3146

}

ContinueFuture Task::taskReadyToRunFuture(bool doSchedule) {
  auto self = shared_from_this();
  if (!ExecutorTaskScheduler::instance().waitForScheduling(self, doSchedule)) {
    return ContinueFuture();
  }
  auto [promise, future] = makeBoltContinuePromiseContract(
      fmt::format("Task::taskReadyToRunFuture {}", taskId_));
  taskReadyToRunPromises_.emplace_back(std::move(promise));
  return std::move(future);
}

void Task::notifyReadyToRun() {
  EventCompletionNotifier readyToRunNotifier;