Skip to content

Instantly share code, notes, and snippets.

@carlosb1
Created October 15, 2015 17:02
Show Gist options
  • Save carlosb1/8b806b9b9bb2a6914ee7 to your computer and use it in GitHub Desktop.
Save carlosb1/8b806b9b9bb2a6914ee7 to your computer and use it in GitHub Desktop.
Thread safe queue
#include <queue>
#include <mutex>
#include <condition_variable>
template <typename T> class threadsafe_queue
{
private:
std::mutex mut;
std::queue<T> data_queue;
std::condition_variable data_cond;
public:
void push (T new_value) {
std::lock_guard<std::mutex> lk(mut);
data_queue.push(new_value);
data_cond.notify_one();
}
void wait_and_pop(T & value) {
std::unique_lock<std::mutex> lk(mut);
data_cond.wait(lk,[this]{return !data_queue.empty();});
value = data_queue.front();
data_queue.pop();
}
};
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment