concurrent_queue-inl.h

Go to the documentation of this file.

#pragma once

namespace tc {
namespace autotune {

template <typename T>
void ConcurrentQueue<T>::enqueue(T t) {
  {
    std::lock_guard<std::mutex> lock(mtx_);
    queue_.push(t);
  }
  cv_.notify_one();
}

template <typename T>
T ConcurrentQueue<T>::dequeueWaitFor(std::chrono::steady_clock::duration d) {
  std::unique_lock<std::mutex> lock(mtx_);
  auto hasElements =
      cv_.wait_for(lock, d, [&]() { return not queue_.empty(); });
  if (not hasElements) {
    return nullptr;
  }
  auto t = queue_.front();
  queue_.pop();
  return t;
}

template <typename T>
bool ConcurrentQueue<T>::empty() const {
  std::lock_guard<std::mutex> lock(mtx_);
  return queue_.empty();
}

template <typename T>
size_t ConcurrentQueue<T>::size() const {
  std::lock_guard<std::mutex> lock(mtx_);
  return queue_.size();
}

} // namespace autotune
} // namespace tc