Searched refs:pull_until (Results 1 – 6 of 6) sorted by relevance
| /third_party/boost/boost/thread/concurrent_queues/ |
| D | sync_priority_queue.hpp | 134 queue_op_status pull_until(const chrono::time_point<WClock,Duration>&, ValueType&);
282 …sync_priority_queue<T,Cont,Cmp>::pull_until(const chrono::time_point<WClock,Duration>& tp, T& elem) in pull_until() function in boost::concurrent::sync_priority_queue
296 return pull_until(chrono::steady_clock::now() + dura, elem); in pull_for()
|
| D | sync_timed_queue.hpp | 133 queue_op_status pull_until(chrono::time_point<clock,Duration> const& tp, T& elem);
383 …sync_timed_queue<T, Clock, TimePoint>::pull_until(chrono::time_point<clock,Duration> const& tp, T&… in pull_until() function in boost::concurrent::sync_timed_queue
|
| /third_party/boost/libs/thread/test/sync/mutual_exclusion/sync_pq/ |
| D | tq_multi_thread_pass.cpp | 60 q->pull_until(steady_clock::now() + hours(1), j); in call_pull_until()
|
| D | pq_single_thread_pass.cpp | 70 boost::queue_op_status st = pq.pull_until(start + milliseconds(500), val); in test_pull_until()
106 boost::queue_op_status st = pq.pull_until(start + milliseconds(500), val); in test_pull_until_when_not_empty()
|
| /third_party/boost/libs/thread/test/ |
| D | test_time_jumps.cpp | 1904 …bool timeout = (q.pull_until(Helper::steadyNow() + Helper::waitDur, i) == boost::queue_op_status::… in testSyncPriorityQueuePullUntilSteady()
1917 …bool timeout = (q.pull_until(Helper::systemNow() + Helper::waitDur, i) == boost::queue_op_status::… in testSyncPriorityQueuePullUntilSystem()
1930 …bool timeout = (q.pull_until(Helper::customNow() + Helper::waitDur, i) == boost::queue_op_status::… in testSyncPriorityQueuePullUntilCustom()
2000 …bool timeout = (q.pull_until(Helper::steadyNow() + Helper::waitDur, i) == boost::queue_op_status::… in testSyncTimedQueuePullUntilEmptySteady()
2013 …bool timeout = (q.pull_until(Helper::systemNow() + Helper::waitDur, i) == boost::queue_op_status::… in testSyncTimedQueuePullUntilEmptySystem()
2026 …bool timeout = (q.pull_until(Helper::customNow() + Helper::waitDur, i) == boost::queue_op_status::… in testSyncTimedQueuePullUntilEmptyCustom()
2084 …bool notReady = (q.pull_until(Helper::steadyNow() + Helper::waitDur, i) == boost::queue_op_status:… in testSyncTimedQueuePullUntilNotReadySteady()
2098 …bool notReady = (q.pull_until(Helper::systemNow() + Helper::waitDur, i) == boost::queue_op_status:… in testSyncTimedQueuePullUntilNotReadySystem()
2112 …bool notReady = (q.pull_until(Helper::customNow() + Helper::waitDur, i) == boost::queue_op_status:… in testSyncTimedQueuePullUntilNotReadyCustom()
2170 …bool succeeded = (q.pull_until(Helper::steadyNow() + typename Helper::milliseconds(10000), i) == b… in testSyncTimedQueuePullUntilSucceedsSteady()
[all …]
|
| /third_party/boost/libs/thread/doc/ |
| D | changes.qbk | 175 * #97 fix a mistake in sync_timed_queue<>::pull_until()
|