2#include <boost/container/deque.hpp>
3#include <boost/thread/mutex.hpp>
4#include <boost/thread/condition.hpp>
5#include <boost/call_traits.hpp>
13 typedef typename container_type::size_type
size_type;
18 void push(
typename boost::call_traits<value_type>::param_type item)
21 boost::mutex::scoped_lock lock(
m_mutex);
29 boost::mutex::scoped_lock lock(
m_mutex);
45 boost::mutex::scoped_lock lock(
m_mutex);
55 boost::mutex::scoped_lock lock(
m_mutex);
63 boost::mutex::scoped_lock lock(
m_mutex);
68 boost::mutex::scoped_lock lock(
m_mutex);
83 boost::mutex::scoped_lock lock(
m_mutex);
value_type try_pop_external()
Definition ThreadSafeQue.h:67
value_type pop()
Definition ThreadSafeQue.h:44
container_type::size_type size_type
Definition ThreadSafeQue.h:13
threadsafe_que()
Definition ThreadSafeQue.h:16
container_type m_container
Definition ThreadSafeQue.h:101
value_type try_pop()
Definition ThreadSafeQue.h:28
boost::mutex m_mutex
Definition ThreadSafeQue.h:102
size_type m_unread
Definition ThreadSafeQue.h:100
bool is_not_empty() const
Definition ThreadSafeQue.h:92
bool is_not_empty_external() const
Definition ThreadSafeQue.h:94
void push(typename boost::call_traits< value_type >::param_type item)
Definition ThreadSafeQue.h:18
boost::condition m_not_empty
Definition ThreadSafeQue.h:103
size_t size()
Definition ThreadSafeQue.h:61
void setWake()
Definition ThreadSafeQue.h:81
void clear()
Definition ThreadSafeQue.h:54
threadsafe_que & operator=(const threadsafe_que &)
threadsafe_que(const threadsafe_que &)
boost::container::deque< T > container_type
Definition ThreadSafeQue.h:12
container_type::value_type value_type
Definition ThreadSafeQue.h:14
bool m_wakeExternally
Definition ThreadSafeQue.h:99