#include <sync_queue.hpp>
Public Types | |
typedef ValueType | value_type |
typedef csbl::deque< ValueType > | underlying_queue_type |
typedef std::size_t | size_type |
typedef queue_op_status | op_status |
Public Member Functions | |
sync_queue () | |
~sync_queue () | |
bool | empty () const |
bool | full () const |
size_type | size () const |
bool | closed () const |
void | close () |
void | push (const value_type &x) |
bool | try_push (const value_type &x) |
bool | try_push (no_block_tag, const value_type &x) |
void | push (BOOST_THREAD_RV_REF(value_type) x) |
bool | try_push (BOOST_THREAD_RV_REF(value_type) x) |
bool | try_push (no_block_tag, BOOST_THREAD_RV_REF(value_type) x) |
void | push_back (const value_type &x) |
queue_op_status | try_push_back (const value_type &x) |
queue_op_status | nonblocking_push_back (const value_type &x) |
queue_op_status | wait_push_back (const value_type &x) |
void | push_back (BOOST_THREAD_RV_REF(value_type) x) |
queue_op_status | try_push_back (BOOST_THREAD_RV_REF(value_type) x) |
queue_op_status | nonblocking_push_back (BOOST_THREAD_RV_REF(value_type) x) |
queue_op_status | wait_push_back (BOOST_THREAD_RV_REF(value_type) x) |
void | pull (value_type &) |
void | pull (ValueType &elem, bool &closed) |
value_type | pull () |
shared_ptr< ValueType > | ptr_pull () |
void | pull_front (value_type &) |
value_type | pull_front () |
bool | try_pull (value_type &) |
bool | try_pull (no_block_tag, value_type &) |
shared_ptr< ValueType > | try_pull () |
queue_op_status | try_pull_front (value_type &) |
queue_op_status | nonblocking_pull_front (value_type &) |
queue_op_status | wait_pull_front (ValueType &elem) |
underlying_queue_type | underlying_queue () |
typedef queue_op_status boost::sync_queue< ValueType >::op_status |
typedef std::size_t boost::sync_queue< ValueType >::size_type |
typedef csbl::deque<ValueType> boost::sync_queue< ValueType >::underlying_queue_type |
typedef ValueType boost::sync_queue< ValueType >::value_type |
|
inline |
References BOOST_ASSERT.
|
inline |
|
inline |
|
inline |
|
inline |
References boost::empty().
Referenced by boost::executors::loop_executor::run_queued_closures(), and boost::user_scheduler::run_queued_closures().
|
inline |
|
inline |
References boost::unique_lock< Mutex >::owns_lock(), and boost::try_to_lock.
|
inline |
References boost::unique_lock< Mutex >::owns_lock(), and boost::try_to_lock.
|
inline |
References boost::move(), boost::unique_lock< Mutex >::owns_lock(), and boost::try_to_lock.
|
inline |
|
inline |
|
inline |
|
inline |
|
inline |
Referenced by boost::operator>>().
|
inline |
|
inline |
References boost::xpressive::push.
|
inline |
References boost::move(), and boost::xpressive::push.
|
inline |
|
inline |
References boost::move(), and boost::xpressive::push_back.
|
inline |
References boost::size().
|
inline |
|
inline |
References boost::unique_lock< Mutex >::owns_lock(), and boost::try_to_lock.
|
inline |
|
inline |
|
inline |
|
inline |
References boost::unique_lock< Mutex >::owns_lock(), and boost::try_to_lock.
|
inline |
References boost::move().
|
inline |
References boost::move(), boost::unique_lock< Mutex >::owns_lock(), and boost::try_to_lock.
|
inline |
|
inline |
References boost::move().
|
inline |
|
inline |
|
inline |
|
inline |
References boost::move().