concurrent_queue.h

Go to the documentation of this file.

#pragma once

#include <condition_variable>
#include <queue>
#include <type_traits>

namespace tc {
namespace autotune {

template <typename T>
class ConcurrentQueue {
 public:
  void enqueue(T t);
  T dequeueWaitFor(std::chrono::steady_clock::duration);
  bool empty() const;
  size_t size() const;

 private:
  mutable std::mutex mtx_;
  std::condition_variable cv_;
  std::queue<T> queue_;
};

} // namespace autotune
} // namespace tc

#include "tc/autotuner/utils/concurrent_queue-inl.h"