| /third_party/boost/boost/thread/concurrent_queues/ |
| D | sync_bounded_queue.hpp | 78 inline bool try_pull(value_type&);
79 inline bool try_pull(no_block_tag,value_type&);
80 inline shared_ptr<ValueType> try_pull();
137 inline bool try_pull(value_type& x, unique_lock<mutex>& lk);
138 inline shared_ptr<value_type> try_pull(unique_lock<mutex>& lk);
322 bool sync_bounded_queue<ValueType>::try_pull(ValueType& elem, unique_lock<mutex>& lk) in try_pull() function in boost::concurrent::sync_bounded_queue
333 shared_ptr<ValueType> sync_bounded_queue<ValueType>::try_pull(unique_lock<mutex>& lk) in try_pull() function in boost::concurrent::sync_bounded_queue
343 bool sync_bounded_queue<ValueType>::try_pull(ValueType& elem) in try_pull() function in boost::concurrent::sync_bounded_queue
346 return try_pull(elem, lk); in try_pull()
371 bool sync_bounded_queue<ValueType>::try_pull(no_block_tag,ValueType& elem) in try_pull() function in boost::concurrent::sync_bounded_queue
[all …]
|
| D | queue_adaptor.hpp | 55 queue_op_status try_pull(value_type& x) { return queue.try_pull(x); } in try_pull() function in boost::concurrent::detail::queue_adaptor_copyable_only
91 queue_op_status try_pull(value_type& x) { return queue.try_pull(x); } in try_pull() function in boost::concurrent::detail::queue_adaptor_movable_only
133 queue_op_status try_pull(value_type& x) { return queue.try_pull(x); } in try_pull() function in boost::concurrent::detail::queue_adaptor_copyable_and_movable
|
| D | sync_priority_queue.hpp | 138 queue_op_status try_pull(ValueType& elem);
157 queue_op_status try_pull(lock_guard<mutex>& lk, ValueType& elem);
158 queue_op_status try_pull(unique_lock<mutex>& lk, ValueType& elem);
302 sync_priority_queue<T,Container,Cmp>::try_pull(unique_lock<mutex>& lk, T& elem) in try_pull() function in boost::concurrent::sync_priority_queue
315 sync_priority_queue<T,Container,Cmp>::try_pull(lock_guard<mutex>& lk, T& elem) in try_pull() function in boost::concurrent::sync_priority_queue
328 sync_priority_queue<T,Container,Cmp>::try_pull(T& elem) in try_pull() function in boost::concurrent::sync_priority_queue
331 return try_pull(lk, elem); in try_pull()
357 return try_pull(lk, elem); in nonblocking_pull()
|
| D | sync_queue.hpp | 67 inline queue_op_status try_pull(value_type&);
73 inline queue_op_status try_pull(value_type& x, unique_lock<mutex>& lk);
139 …queue_op_status sync_queue<ValueType, Container>::try_pull(ValueType& elem, unique_lock<mutex>& lk) in try_pull() function in boost::concurrent::sync_queue
159 queue_op_status sync_queue<ValueType, Container>::try_pull(ValueType& elem) in try_pull() function in boost::concurrent::sync_queue
162 return try_pull(elem, lk); in try_pull()
180 return try_pull(elem, lk); in nonblocking_pull()
|
| D | queue_base.hpp | 55 virtual queue_op_status try_pull(value_type&) = 0;
87 virtual queue_op_status try_pull(value_type&) = 0;
126 virtual queue_op_status try_pull(value_type&) = 0;
|
| D | sync_timed_queue.hpp | 137 queue_op_status try_pull(T& elem);
176 queue_op_status try_pull(unique_lock<mutex>&, T& elem);
177 queue_op_status try_pull(lock_guard<mutex>&, T& elem);
405 queue_op_status sync_timed_queue<T, Clock, TimePoint>::try_pull(unique_lock<mutex>& lk, T& elem) in try_pull() function in boost::concurrent::sync_timed_queue
417 queue_op_status sync_timed_queue<T, Clock, TimePoint>::try_pull(lock_guard<mutex>& lk, T& elem) in try_pull() function in boost::concurrent::sync_timed_queue
430 queue_op_status sync_timed_queue<T, Clock, TimePoint>::try_pull(T& elem) in try_pull() function in boost::concurrent::sync_timed_queue
433 return try_pull(lk, elem); in try_pull()
459 return try_pull(lk, elem); in nonblocking_pull()
|
| D | queue_views.hpp | 83 queue_op_status try_pull(value_type& x) { return queue->try_pull(x); } in try_pull() function in boost::concurrent::queue_front_view
|
| D | deque_views.hpp | 54 queue_op_status try_pull(value_type& x) { return queue->try_pull_back(x); } in try_pull() function in boost::concurrent::deque_back_view
97 queue_op_status try_pull(value_type& x) { return queue->try_pull_front(x); } in try_pull() function in boost::concurrent::deque_front_view
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/sync_bounded_queue/ |
| D | single_thread_pass.cpp | 56 BOOST_TEST(! q.try_pull(i)); in main()
65 BOOST_TEST(! q.try_pull()); in main()
202 BOOST_TEST(q.try_pull(i)); in main()
214 BOOST_TEST(q.try_pull(boost::no_block, i)); in main()
225 boost::shared_ptr<int> i = q.try_pull(); in main()
248 BOOST_TEST(q.try_pull()); in main()
|
| /third_party/boost/boost/thread/ |
| D | user_scheduler.hpp | 44 if (work_queue.try_pull(task) == queue_op_status::success) in try_executing_one()
|
| /third_party/boost/boost/thread/executors/ |
| D | loop_executor.hpp | 67 work_queue.try_pull(task); in execute_one()
|
| D | serial_executor.hpp | 80 if (work_queue.try_pull(task) == queue_op_status::success) in try_executing_one()
|
| D | basic_thread_pool.hpp | 55 if (work_queue.try_pull(task) == queue_op_status::success) in try_executing_one()
|
| /third_party/boost/libs/thread/example/ |
| D | producer_consumer2.cpp | 84 queue_op_status st = sbq.try_pull(r); in consumer2()
|
| D | producer_consumer.cpp | 81 queue_op_status st = sbq.try_pull(r); in consumer2()
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/queue_views/ |
| D | single_thread_pass.cpp | 73 BOOST_TEST( boost::queue_op_status::empty == q.try_pull(i)); in main()
296 BOOST_TEST(boost::queue_op_status::success == q.try_pull(i)); in main()
311 BOOST_TEST(boost::queue_op_status::success == q.try_pull(nc)); in main()
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/deque_views/ |
| D | single_thread_pass.cpp | 73 BOOST_TEST( boost::queue_op_status::empty == q.try_pull(i)); in main()
295 BOOST_TEST(boost::queue_op_status::success == q.try_pull(i)); in main()
310 BOOST_TEST(boost::queue_op_status::success == q.try_pull(nc)); in main()
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/sync_queue/ |
| D | single_thread_pass.cpp | 227 BOOST_TEST(boost::queue_op_status::success == q.try_pull(i)); in main()
240 BOOST_TEST(boost::queue_op_status::success == q.try_pull(nc)); in main()
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/sync_pq/ |
| D | pq_single_thread_pass.cpp | 278 BOOST_TEST(boost::queue_op_status::success == q.try_pull(i)); in main()
292 BOOST_TEST(boost::queue_op_status::success == q.try_pull(nc)); in main()
|
| /third_party/boost/libs/thread/doc/ |
| D | sync_queues_ref.qbk | 810 queue_op_status try_pull(value_type& x);
|