Method Start

src/master/procedure_executor.cc:31–39

      thread_pool_(new ThreadPool(FLAGS_procedure_executor_thread_num)) {}

bool ProcedureExecutor::Start() {
  std::unique_lock<std::mutex> lock(mutex_);
  if (running_) {
    return false;
  }
  running_ = true;
  schedule_thread_ = std::move(std::thread(&ProcedureExecutor::ScheduleProcedures, this));
  return true;
}

void ProcedureExecutor::Stop() {
  mutex_.lock();