| /third_party/boost/boost/thread/concurrent_queues/ |
| D | queue_adaptor.hpp | 61 queue_op_status wait_pull(value_type& x) { return queue.wait_pull(x); } in wait_pull() function in boost::concurrent::detail::queue_adaptor_copyable_only
95 queue_op_status wait_pull(value_type& x) { return queue.wait_pull(x); } in wait_pull() function in boost::concurrent::detail::queue_adaptor_movable_only
139 queue_op_status wait_pull(value_type& x) { return queue.wait_pull(x); } in wait_pull() function in boost::concurrent::detail::queue_adaptor_copyable_and_movable
|
| D | sync_queue.hpp | 69 inline queue_op_status wait_pull(ValueType& elem);
74 inline queue_op_status wait_pull(value_type& x, unique_lock<mutex>& lk);
150 …queue_op_status sync_queue<ValueType, Container>::wait_pull(ValueType& elem, unique_lock<mutex>& l… in wait_pull() function in boost::concurrent::sync_queue
166 queue_op_status sync_queue<ValueType, Container>::wait_pull(ValueType& elem) in wait_pull() function in boost::concurrent::sync_queue
169 return wait_pull(elem, lk); in wait_pull()
|
| D | queue_base.hpp | 61 virtual queue_op_status wait_pull(ValueType& elem) = 0;
91 virtual queue_op_status wait_pull(value_type& elem) = 0;
132 virtual queue_op_status wait_pull(value_type& elem) = 0;
|
| D | sync_priority_queue.hpp | 139 queue_op_status wait_pull(ValueType& elem);
160 queue_op_status wait_pull(unique_lock<mutex>& lk, ValueType& elem);
336 queue_op_status sync_priority_queue<T,Container,Cmp>::wait_pull(unique_lock<mutex>& lk, T& elem) in wait_pull() function in boost::concurrent::sync_priority_queue
345 queue_op_status sync_priority_queue<T,Container,Cmp>::wait_pull(T& elem) in wait_pull() function in boost::concurrent::sync_priority_queue
348 return wait_pull(lk, elem); in wait_pull()
|
| D | queue_views.hpp | 87 queue_op_status wait_pull(value_type& x) { return queue->wait_pull(x); } in wait_pull() function in boost::concurrent::queue_front_view
|
| D | deque_views.hpp | 61 queue_op_status wait_pull(value_type& x) { return queue->wait_pull_back(x); } in wait_pull() function in boost::concurrent::deque_back_view
104 queue_op_status wait_pull(value_type& x) { return queue->wait_pull_front(x); } in wait_pull() function in boost::concurrent::deque_front_view
|
| D | sync_timed_queue.hpp | 138 queue_op_status wait_pull(T& elem);
179 queue_op_status wait_pull(unique_lock<mutex>& lk, T& elem);
438 queue_op_status sync_timed_queue<T, Clock, TimePoint>::wait_pull(unique_lock<mutex>& lk, T& elem) in wait_pull() function in boost::concurrent::sync_timed_queue
447 queue_op_status sync_timed_queue<T, Clock, TimePoint>::wait_pull(T& elem) in wait_pull() function in boost::concurrent::sync_timed_queue
450 return wait_pull(lk, elem); in wait_pull()
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/sync_queue/ |
| D | single_thread_pass.cpp | 278 BOOST_TEST(boost::queue_op_status::success == q.wait_pull(nc)); in main()
290 BOOST_TEST(boost::queue_op_status::success == q.wait_pull(i)); in main()
303 BOOST_TEST(boost::queue_op_status::success == q.wait_pull(nc)); in main()
353 BOOST_TEST(boost::queue_op_status::success == q.wait_pull(i)); in main()
367 BOOST_TEST(boost::queue_op_status::closed == q.wait_pull(i)); in main()
|
| D | multi_thread_pass.cpp | 75 return q_->wait_pull(v); in operator ()()
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/sync_pq/ |
| D | pq_single_thread_pass.cpp | 332 BOOST_TEST(boost::queue_op_status::success == q.wait_pull(nc)); in main()
345 BOOST_TEST(boost::queue_op_status::success == q.wait_pull(i)); in main()
359 BOOST_TEST(boost::queue_op_status::success == q.wait_pull(nc)); in main()
410 BOOST_TEST(boost::queue_op_status::success == q.wait_pull(i)); in main()
424 BOOST_TEST(boost::queue_op_status::closed == q.wait_pull(i)); in main()
|
| D | tq_single_thread_pass.cpp | 84 boost::queue_op_status st = pq.wait_pull(val); in test_all_with_try()
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/queue_views/ |
| D | single_thread_pass.cpp | 354 BOOST_TEST(boost::queue_op_status::success == q.wait_pull(nc)); in main()
368 BOOST_TEST(boost::queue_op_status::success == q.wait_pull(i)); in main()
383 BOOST_TEST(boost::queue_op_status::success == q.wait_pull(nc)); in main()
447 BOOST_TEST(boost::queue_op_status::success == q.wait_pull(i)); in main()
462 BOOST_TEST(boost::queue_op_status::closed == q.wait_pull(i)); in main()
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/deque_views/ |
| D | single_thread_pass.cpp | 354 BOOST_TEST(boost::queue_op_status::success == q.wait_pull(nc)); in main()
368 BOOST_TEST(boost::queue_op_status::success == q.wait_pull(i)); in main()
383 BOOST_TEST(boost::queue_op_status::success == q.wait_pull(nc)); in main()
447 BOOST_TEST(boost::queue_op_status::success == q.wait_pull(i)); in main()
462 BOOST_TEST(boost::queue_op_status::closed == q.wait_pull(i)); in main()
|
| /third_party/boost/boost/thread/executors/detail/ |
| D | priority_executor_base.hpp | 62 queue_op_status st = _workq.wait_pull(task); in loop()
|
| /third_party/boost/boost/thread/executors/ |
| D | loop_executor.hpp | 66 work_queue.wait_pull(task) : in execute_one()
|
| D | basic_thread_pool.hpp | 93 queue_op_status st = work_queue.wait_pull(task); in worker_thread()
|
| /third_party/boost/libs/thread/example/ |
| D | producer_consumer2.cpp | 104 queue_op_status res = sbq.wait_pull(r); in consumer3()
|
| D | producer_consumer.cpp | 101 queue_op_status res = sbq.wait_pull(r); in consumer3()
|
| /third_party/boost/libs/thread/test/ |
| D | test_time_jumps.cpp | 2214 bool succeeded = (q.wait_pull(i) == boost::queue_op_status::success); in testSyncTimedQueueWaitPullSucceedsSteady()
2228 bool succeeded = (q.wait_pull(i) == boost::queue_op_status::success); in testSyncTimedQueueWaitPullSucceedsSystem()
2242 bool succeeded = (q.wait_pull(i) == boost::queue_op_status::success); in testSyncTimedQueueWaitPullSucceedsCustom()
|
| /third_party/boost/libs/thread/doc/ |
| D | sync_queues_ref.qbk | 814 queue_op_status wait_pull(value_type& x);
|