Method push

src/threaded_queue.hh:85–93

  // Add an element to the queue.
  template <void (std::deque<T>::*Push)(T &&)> void push(T &&t, bool priority) {
    std::lock_guard<std::mutex> lock(mutex_);
    if (priority)
      (priority_.*Push)(std::move(t));
    else
      (queue_.*Push)(std::move(t));
    ++total_count_;
    waiter_->cv.notify_one();
  }

  void pushBack(T &&t, bool priority = false) { push<&std::deque<T>::push_back>(std::move(t), priority); }