Searched refs:pull_for (Results 1 – 5 of 5) sorted by relevance
| /third_party/boost/boost/thread/concurrent_queues/ |
| D | sync_priority_queue.hpp | 136 queue_op_status pull_for(const chrono::duration<Rep,Period>&, ValueType&);
294 sync_priority_queue<T,Cont,Cmp>::pull_for(const chrono::duration<Rep,Period>& dura, T& elem) in pull_for() function in boost::concurrent::sync_priority_queue
|
| D | sync_timed_queue.hpp | 135 queue_op_status pull_for(chrono::duration<Rep,Period> const& dura, T& elem);
395 sync_timed_queue<T, Clock, TimePoint>::pull_for(chrono::duration<Rep,Period> const& dura, T& elem) in pull_for() function in boost::concurrent::sync_timed_queue
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/sync_pq/ |
| D | tq_multi_thread_pass.cpp | 74 q->pull_for(hours(1), j); in call_pull_for()
|
| D | pq_single_thread_pass.cpp | 59 boost::queue_op_status st = pq.pull_for(milliseconds(500), val); in test_pull_for()
93 boost::queue_op_status st = pq.pull_for(milliseconds(500), val); in test_pull_for_when_not_empty()
|
| /third_party/boost/libs/thread/test/ |
| D | test_time_jumps.cpp | 1891 bool timeout = (q.pull_for(Helper::waitDur, i) == boost::queue_op_status::timeout); in testSyncPriorityQueuePullFor()
1961 bool timeout = (q.pull_for(Helper::waitDur, i) == boost::queue_op_status::timeout); in testSyncTimedQueuePullForEmptySteady()
1974 bool timeout = (q.pull_for(Helper::waitDur, i) == boost::queue_op_status::timeout); in testSyncTimedQueuePullForEmptySystem()
1987 bool timeout = (q.pull_for(Helper::waitDur, i) == boost::queue_op_status::timeout); in testSyncTimedQueuePullForEmptyCustom()
2042 bool notReady = (q.pull_for(Helper::waitDur, i) == boost::queue_op_status::not_ready); in testSyncTimedQueuePullForNotReadySteady()
2056 bool notReady = (q.pull_for(Helper::waitDur, i) == boost::queue_op_status::not_ready); in testSyncTimedQueuePullForNotReadySystem()
2070 bool notReady = (q.pull_for(Helper::waitDur, i) == boost::queue_op_status::not_ready); in testSyncTimedQueuePullForNotReadyCustom()
2128 …bool succeeded = (q.pull_for(typename Helper::milliseconds(10000), i) == boost::queue_op_status::s… in testSyncTimedQueuePullForSucceedsSteady()
2142 …bool succeeded = (q.pull_for(typename Helper::milliseconds(10000), i) == boost::queue_op_status::s… in testSyncTimedQueuePullForSucceedsSystem()
2156 …bool succeeded = (q.pull_for(typename Helper::milliseconds(10000), i) == boost::queue_op_status::s… in testSyncTimedQueuePullForSucceedsCustom()
|