Home
last modified time | relevance | path

Searched refs:sync_queue (Results 1 – 13 of 13) sorted by relevance

/third_party/boost/boost/thread/concurrent_queues/
Dsync_queue.hpp33 class sync_queue class
46 BOOST_THREAD_NO_COPYABLE(sync_queue)
47 inline sync_queue();
50 inline ~sync_queue();
106 sync_queue<ValueType, Container>::sync_queue() : in sync_queue() function in boost::concurrent::sync_queue
134 sync_queue<ValueType, Container>::~sync_queue() in ~sync_queue()
139 …queue_op_status sync_queue<ValueType, Container>::try_pull(ValueType& elem, unique_lock<mutex>& lk) in try_pull()
150 …queue_op_status sync_queue<ValueType, Container>::wait_pull(ValueType& elem, unique_lock<mutex>& l… in wait_pull()
159 queue_op_status sync_queue<ValueType, Container>::try_pull(ValueType& elem) in try_pull()
166 queue_op_status sync_queue<ValueType, Container>::wait_pull(ValueType& elem) in wait_pull()
[all …]
/third_party/boost/libs/thread/test/sync/mutual_exclusion/sync_queue/
Dsingle_thread_pass.cpp43 boost::sync_queue<int> q; in main()
53 boost::sync_queue<non_copyable> q; in main()
63 boost::sync_queue<non_copyable> q; in main()
74 boost::sync_queue<int> q; in main()
84 boost::sync_queue<int> q; in main()
94 boost::sync_queue<int> q; in main()
103 boost::sync_queue<int> q; in main()
114 boost::sync_queue<non_copyable> q; in main()
124 boost::sync_queue<non_copyable> q; in main()
135 boost::sync_queue<int> q; in main()
[all …]
Dmulti_thread_pass.cpp28 boost::sync_queue<ValueType> *q_;
31 call_push(boost::sync_queue<ValueType> *q, boost::barrier *go) : in call_push()
46 boost::sync_queue<ValueType> *q_;
49 call_pull(boost::sync_queue<ValueType> *q, boost::barrier *go) : in call_pull()
64 boost::sync_queue<ValueType> *q_;
67 call_wait_pull(boost::sync_queue<ValueType> *q, boost::barrier *go) : in call_wait_pull()
81 boost::sync_queue<int> q; in test_concurrent_push_and_pull_on_empty_queue()
108 boost::sync_queue<int> q; in test_concurrent_push_and_wait_pull_on_empty_queue()
139 boost::sync_queue<int> q; in test_concurrent_wait_pull_and_close_on_empty_queue()
169 boost::sync_queue<int> q; in test_concurrent_push_on_empty_queue()
[all …]
/third_party/boost/libs/thread/test/sync/mutual_exclusion/queue_views/
Dsingle_thread_pass.cpp50 boost::queue_adaptor<boost::sync_queue<int> > sq; in main()
59 boost::queue_adaptor<boost::sync_queue<int> > sq; in main()
70 boost::queue_adaptor<boost::sync_queue<int> > sq; in main()
81 boost::queue_adaptor<boost::sync_queue<int> > sq; in main()
91 boost::queue_adaptor<boost::sync_queue<int> > sq; in main()
105 boost::queue_adaptor<boost::sync_queue<non_copyable> > sq; in main()
117 boost::queue_adaptor<boost::sync_queue<non_copyable> > q; in main()
131 boost::queue_adaptor<boost::sync_queue<int> > sq; in main()
142 boost::queue_adaptor<boost::sync_queue<int> > sq; in main()
153 boost::queue_adaptor<boost::sync_queue<int> > sq; in main()
[all …]
/third_party/boost/libs/thread/example/
Dproducer_consumer.cpp27 void producer(the_ostream & /*mos*/, boost::sync_queue<int> & sbq) in producer()
51 boost::sync_queue<int> & sbq) in consumer()
74 void consumer2(the_ostream &/*mos*/, boost::sync_queue<int> & sbq) in consumer2()
94 void consumer3(the_ostream &/*mos*/, boost::sync_queue<int> & sbq) in consumer3()
129 sync_queue<int> sbq; in main()
Dproducer_consumer2.cpp132 queue_adaptor<sync_queue<int> > sbq; in main()
/third_party/boost/libs/thread/doc/
Dsync_queues_ref.qbk64 …sync_queue::closed (when they do not). Elements already on the queue may be pulled off. When a que…
964 #include <boost/thread/sync_queue.hpp>
968 class sync_queue;
972 sync_queue<ValueType>& operator<<(sync_queue<ValueType>& sbq, ValueType&& elem);
974 sync_queue<ValueType>& operator<<(sync_queue<ValueType>& sbq, ValueType const&elem);
976 sync_queue<ValueType>& operator>>(sync_queue<ValueType>& sbq, ValueType &elem);
980 [section:sync_queue Class template `sync_queue<>`]
982 #include <boost/thread/sync_queue.hpp>
987 class sync_queue
994 sync_queue(sync_queue const&) = delete;
[all …]
Dcompliance.qbk183 … [[X.2.1] [Locking Buffer Queue] [Partial] [ classes sync_queue and a sync_bounded_queue. ]]
/third_party/boost/boost/thread/
Duser_scheduler.hpp31 sync_queue<work > work_queue;
189 sync_queue<work>::underlying_queue_type q = work_queue.underlying_queue(); in run_queued_closures()
/third_party/boost/boost/thread/executors/
Dloop_executor.hpp38 concurrent::sync_queue<work > work_queue;
195 sync_queue<work>::underlying_queue_type q = work_queue.underlying_queue(); in run_queued_closures()
Dserial_executor.hpp44 concurrent::sync_queue<work > work_queue;
Dbasic_thread_pool.hpp42 concurrent::sync_queue<work > work_queue;
/third_party/boost/libs/thread/test/
DJamfile.v2767 …[ thread-run2-noit ./sync/mutual_exclusion/sync_queue/single_thread_pass.cpp : sync_queue__single_…
768 …[ thread-run2-noit ./sync/mutual_exclusion/sync_queue/multi_thread_pass.cpp : sync_queue__multi_th…