Home
last modified time | relevance | path

Searched refs:throw_if_closed (Results 1 – 7 of 7) sorted by relevance

/third_party/boost/boost/thread/concurrent_queues/detail/
Dsync_queue_base.hpp86 inline void throw_if_closed(unique_lock<mutex>&);
87 inline void throw_if_closed(lock_guard<mutex>&);
165 void sync_queue_base<ValueType, Queue>::throw_if_closed(unique_lock<mutex>& lk) in throw_if_closed() function in boost::concurrent::detail::sync_queue_base
173 void sync_queue_base<ValueType, Queue>::throw_if_closed(lock_guard<mutex>& lk) in throw_if_closed() function in boost::concurrent::detail::sync_queue_base
Dsync_deque_base.hpp86 inline void throw_if_closed(unique_lock<mutex>&);
87 inline void throw_if_closed(lock_guard<mutex>&);
165 void sync_deque_base<ValueType, Queue>::throw_if_closed(unique_lock<mutex>& lk) in throw_if_closed() function in boost::concurrent::detail::sync_deque_base
173 void sync_deque_base<ValueType, Queue>::throw_if_closed(lock_guard<mutex>& lk) in throw_if_closed() function in boost::concurrent::detail::sync_deque_base
/third_party/boost/boost/thread/concurrent_queues/
Dsync_priority_queue.hpp175 super::throw_if_closed(lk); in push()
182 super::throw_if_closed(lk); in push()
197 super::throw_if_closed(lk); in push()
204 super::throw_if_closed(lk); in push()
253 if (has_been_closed) super::throw_if_closed(lk); in pull()
274 if (has_been_closed) super::throw_if_closed(lk); in pull()
Dsync_bounded_queue.hpp133 inline void throw_if_closed(unique_lock<mutex>&);
326 throw_if_closed(lk); in try_pull()
337 throw_if_closed(lk); in try_pull()
400 void sync_bounded_queue<ValueType>::throw_if_closed(unique_lock<mutex>&) in throw_if_closed() function in boost::concurrent::sync_bounded_queue
414 throw_if_closed(lk); in wait_until_not_empty()
504 throw_if_closed(lk); in try_push()
580 throw_if_closed(lk); in wait_until_not_full()
610 throw_if_closed(lk); in try_push()
Dsync_deque.hpp188 if (has_been_closed) super::throw_if_closed(lk); in pull_front()
198 if (has_been_closed) super::throw_if_closed(lk); in pull_front()
244 super::throw_if_closed(lk); in push_back()
293 super::throw_if_closed(lk); in push_back()
Dsync_queue.hpp188 if (has_been_closed) super::throw_if_closed(lk); in pull()
198 if (has_been_closed) super::throw_if_closed(lk); in pull()
244 super::throw_if_closed(lk); in push()
293 super::throw_if_closed(lk); in push()
Dsync_timed_queue.hpp345 if (has_been_closed) super::throw_if_closed(lk); in pull()
375 if (has_been_closed) super::throw_if_closed(lk); in pull()