diff options
Diffstat (limited to 'boost/thread/concurrent_queues/queue_views.hpp')
-rw-r--r-- | boost/thread/concurrent_queues/queue_views.hpp | 36 |
1 files changed, 13 insertions, 23 deletions
diff --git a/boost/thread/concurrent_queues/queue_views.hpp b/boost/thread/concurrent_queues/queue_views.hpp index 1c06af8297..5a4512dd6e 100644 --- a/boost/thread/concurrent_queues/queue_views.hpp +++ b/boost/thread/concurrent_queues/queue_views.hpp @@ -43,27 +43,17 @@ namespace concurrent // Modifiers void close() { queue->close(); } - void push(const value_type& x) { queue->push_back(x); } + void push(const value_type& x) { queue->push(x); } - void pull(value_type& x) { queue->pull_back(x); } - // enable_if is_nothrow_copy_movable<value_type> - value_type pull() { return queue->pull_back(); } - - queue_op_status try_push(const value_type& x) { return queue->try_push_back(x); } - - queue_op_status try_pull(value_type& x) { return queue->try_pull_back(x); } - - queue_op_status nonblocking_push(const value_type& x) { return queue->nonblocking_push_back(x); } - - queue_op_status nonblocking_pull(value_type& x) { return queue->nonblocking_pull_back(x); } + queue_op_status try_push(const value_type& x) { return queue->try_push(x); } - queue_op_status wait_push(const value_type& x) { return queue->wait_push_back(x); } - queue_op_status wait_pull(value_type& x) { return queue->wait_pull_back(x); } + queue_op_status nonblocking_push(const value_type& x) { return queue->nonblocking_push(x); } + queue_op_status wait_push(const value_type& x) { return queue->wait_push(x); } - void push(BOOST_THREAD_RV_REF(value_type) x) { queue->push_back(boost::move(x)); } - queue_op_status try_push(BOOST_THREAD_RV_REF(value_type) x) { return queue->try_push_back(boost::move(x)); } - queue_op_status nonblocking_push(BOOST_THREAD_RV_REF(value_type) x) { return queue->nonblocking_push_back(boost::move(x)); } - queue_op_status wait_push(BOOST_THREAD_RV_REF(value_type) x) { return queue->wait_push_back(boost::move(x)); } + void push(BOOST_THREAD_RV_REF(value_type) x) { queue->push(boost::move(x)); } + queue_op_status try_push(BOOST_THREAD_RV_REF(value_type) x) { return queue->try_push(boost::move(x)); } + queue_op_status nonblocking_push(BOOST_THREAD_RV_REF(value_type) x) { return queue->nonblocking_push(boost::move(x)); } + queue_op_status wait_push(BOOST_THREAD_RV_REF(value_type) x) { return queue->wait_push(boost::move(x)); } }; template <typename Queue> @@ -88,20 +78,20 @@ namespace concurrent void push(const value_type& x) { queue->push_front(x); } - void pull(value_type& x) { queue->pull_front(x); }; + void pull(value_type& x) { queue->pull(x); }; // enable_if is_nothrow_copy_movable<value_type> - value_type pull() { return queue->pull_front(); } + value_type pull() { return queue->pull(); } queue_op_status try_push(const value_type& x) { return queue->try_push_front(x); } - queue_op_status try_pull(value_type& x) { return queue->try_pull_front(x); } + queue_op_status try_pull(value_type& x) { return queue->try_pull(x); } queue_op_status nonblocking_push(const value_type& x) { return queue->nonblocking_push_front(x); } - queue_op_status nonblocking_pull(value_type& x) { return queue->nonblocking_pull_front(x); } + queue_op_status nonblocking_pull(value_type& x) { return queue->nonblocking_pull(x); } queue_op_status wait_push(const value_type& x) { return queue->wait_push_front(x); } - queue_op_status wait_pull(value_type& x) { return queue->wait_pull_front(x); } + queue_op_status wait_pull(value_type& x) { return queue->wait_pull(x); } void push(BOOST_THREAD_RV_REF(value_type) x) { queue->push_front(forward<value_type>(x)); } queue_op_status try_push(BOOST_THREAD_RV_REF(value_type) x) { return queue->try_push_front(forward<value_type>(x)); } queue_op_status nonblocking_push(BOOST_THREAD_RV_REF(value_type) x) { return queue->nonblocking_push_front(forward<value_type>(x)); } |