throw "element not found";
}
pthread_mutex_lock(&_rlock);
T _temp = _list.front( );
_list.pop_front( );
pthread_mutex_unlock(&_rlock);
return _temp;
}
设计并发阻塞队列
目前，如果读线程试图从没有数据的队列读取数据，仅仅会抛出异常并继续执行。但是，这种做法不总是我们想要的，读线程很可能希望等待（即阻塞自身），直到有数据可用时为止。这种队列称为阻塞的队列。如何让读线程在发现队列是空的之后等待？一种做法是定期轮询队列。但是，因为这种做法不保证队列中有数据可用，它可能会导致浪费大量 CPU 周期。推荐的方法是使用条件变量，即 pthread_cond_t 类型的变量。
template <typename T>
class BlockingQueue
{
public:
BlockingQueue ( )
{
pthread_mutexattr_init(&_attr);
// set lock recursive
pthread_mutexattr_settype(&_attr,PTHREAD_MUTEX_RECURSIVE_NP);
pthread_mutex_init(&_lock,&_attr);
pthread_cond_init(&_cond, NULL);
}
~BlockingQueue ( )
{
pthread_mutex_destroy(&_lock);
pthread_cond_destroy(&_cond);
}
void push(const T& data);
bool push(const T& data, const int seconds); //time-out push
T pop( );
T pop(const int seconds); // time-out pop
private:
list<T> _list;
pthread_mutex_t _lock;
pthread_mutexattr_t _attr;
pthread_cond_t _cond;
};
template <typename T>
T BlockingQueue<T>::pop( )
{
pthread_mutex_lock(&_lock);
while (_list.empty( ))
{
pthread_cond_wait(&_cond, &_lock) ;
}
T _temp = _list.front( );
_list.pop_front( );
pthread_mutex_unlock(&_lock);
return _temp;
}
template <typename T>
void BlockingQueue <T>::push(const T& value )
{
pthread_mutex_lock(&_lock);
const bool was_empty = _list.empty( );
_list.push_back(value);
pthread_mutex_unlock(&_lock);
if (was_empty)
pthread_cond_broadcast(&_cond);
