#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().