Method enqueue

cachelib/navy/scheduler/ThreadPoolJobQueue.cpp:43–63

} // namespace

void JobQueue::enqueue(Job job, folly::StringPiece name, QueuePos pos) {
  bool wasEmpty = false;
  {
    std::lock_guard<std::mutex> lock{mutex_};
    wasEmpty = queue_.empty() && processing_ == 0;
    if (!stop_) {
      if (pos == QueuePos::Front) {
        queue_.emplace_front(std::move(job), name);
      } else {
        XDCHECK_EQ(pos, QueuePos::Back);
        queue_.emplace_back(std::move(job), name);
      }
      enqueueCount_++;
    }
    maxQueueLen_ = std::max<uint64_t>(maxQueueLen_, queue_.size());
  }

  if (wasEmpty) {
    cv_.notify_one();
  }
}

void JobQueue::requestStop() {
  std::lock_guard<std::mutex> lock{mutex_};