115 lines
1.7 KiB
C++
115 lines
1.7 KiB
C++
#ifndef BLOCKING_QUEUE_H
|
|
#define BLOCKING_QUEUE_H
|
|
|
|
//#include <boost/thread/mutex.hpp>
|
|
//#include <boost/thread/condition_variable.hpp>
|
|
#if defined(WIN32) || defined(_WIN64)
|
|
#include <Windows.h>
|
|
#endif
|
|
#include <mutex>
|
|
#include <condition_variable>
|
|
#include <deque>
|
|
#include <iostream>
|
|
#include <exception>
|
|
using namespace std;
|
|
|
|
template <typename T>
|
|
class BlockingQueue
|
|
{
|
|
private:
|
|
BlockingQueue(const BlockingQueue& rhs);
|
|
BlockingQueue& operator =(const BlockingQueue& rhs);
|
|
mutable std::mutex _mutex;
|
|
std::condition_variable _condvar;
|
|
deque<T> _queue;
|
|
bool isShutDown;
|
|
T tRet;
|
|
|
|
public:
|
|
BlockingQueue()
|
|
: _mutex()
|
|
, _condvar()
|
|
, _queue()
|
|
, isShutDown(false)
|
|
{
|
|
}
|
|
|
|
~BlockingQueue()
|
|
{
|
|
ShutDown();
|
|
std::cout << "blocking queue release" << std::endl;
|
|
}
|
|
|
|
void Clear()
|
|
{
|
|
lock_guard<mutex> lock(_mutex);
|
|
_condvar.notify_all();
|
|
_queue.clear();
|
|
}
|
|
|
|
void ShutDown()
|
|
{
|
|
isShutDown = true;
|
|
_condvar.notify_all();
|
|
_queue.clear();
|
|
}
|
|
|
|
bool IsShutDown()
|
|
{
|
|
return isShutDown;
|
|
}
|
|
|
|
void Put(const T task)
|
|
{
|
|
lock_guard<mutex> lock(_mutex);
|
|
if (!isShutDown)
|
|
{
|
|
{
|
|
_queue.push_back(task);
|
|
}
|
|
_condvar.notify_all();
|
|
}
|
|
|
|
}
|
|
|
|
T Take()
|
|
{
|
|
unique_lock<mutex> lock(_mutex);
|
|
if (_queue.size() <= 0)
|
|
_condvar.wait(lock);
|
|
|
|
if (isShutDown || _queue.empty())
|
|
{
|
|
return tRet;
|
|
}
|
|
|
|
T front(_queue.front());
|
|
_queue.pop_front();
|
|
|
|
return front;
|
|
}
|
|
|
|
T Front()
|
|
{
|
|
unique_lock<mutex> lock(_mutex);
|
|
if (_queue.size() <= 0)
|
|
_condvar.wait(lock);
|
|
|
|
if (isShutDown || _queue.empty())
|
|
{
|
|
return tRet;
|
|
}
|
|
|
|
T front(_queue.front());
|
|
return front;
|
|
}
|
|
|
|
size_t Size() const
|
|
{
|
|
lock_guard<mutex> lock(_mutex);
|
|
return _queue.size();
|
|
}
|
|
};
|
|
|
|
#endif
|