Tensor Comprehensions
|
#include <concurrent_queue.h>
Public Member Functions | |
void | enqueue (T t) |
T | dequeueWaitFor (std::chrono::steady_clock::duration) |
bool | empty () const |
size_t | size () const |
Private Attributes | |
std::mutex | mtx_ |
std::condition_variable | cv_ |
std::queue< T > | queue_ |
A basic concurrent queue synchronized with a lock. We will never need a more intricate implementation for anything related to compilation and autotuning.
T tc::autotune::ConcurrentQueue< T >::dequeueWaitFor | ( | std::chrono::steady_clock::duration | d | ) |
bool tc::autotune::ConcurrentQueue< T >::empty | ( | ) | const |
void tc::autotune::ConcurrentQueue< T >::enqueue | ( | T | t | ) |
size_t tc::autotune::ConcurrentQueue< T >::size | ( | ) | const |
|
private |
|
mutableprivate |
|
private |