Method ScheduleReactorTask

be/src/kudu/rpc/reactor.cc:938–954

}

void Reactor::ScheduleReactorTask(ReactorTask* task) {
  bool was_empty;
  {
    std::unique_lock<LockType> l(lock_);
    if (closing_) {
      // We guarantee the reactor lock is not taken when calling Abort().
      l.unlock();
      task->Abort(ShutdownError(false));
      return;
    }
    was_empty = pending_tasks_.empty();
    pending_tasks_.push_back(*task);
  }
  if (was_empty) {
    thread_.WakeThread();
  }
}

bool Reactor::DrainTaskQueue(boost::intrusive::list<ReactorTask>* tasks) { // NOLINT(*)
  std::lock_guard<LockType> l(lock_);