| /third_party/boost/libs/thread/example/ |
| D | producer_consumer2.cpp | 30 void producer(the_ostream &/*mos*/, boost::queue_back<int> sbq) in producer() argument
36 sbq.push(i); in producer()
54 boost::queue_front<int> sbq) in consumer() argument
61 sbq.pull(r); in consumer()
77 void consumer2(the_ostream &/*mos*/, boost::queue_front<int> sbq) in consumer2() argument
84 queue_op_status st = sbq.try_pull(r); in consumer2()
97 void consumer3(the_ostream &/*mos*/, boost::queue_front<int> sbq) in consumer3() argument
104 queue_op_status res = sbq.wait_pull(r); in consumer3()
132 queue_adaptor<sync_queue<int> > sbq; in main() local
136 … scoped_thread<> t11(boost::thread(producer, boost::ref(mcerr), concurrent::queue_back<int>(sbq))); in main()
[all …]
|
| D | producer_consumer.cpp | 27 void producer(the_ostream & /*mos*/, boost::sync_queue<int> & sbq) in producer() argument
33 sbq.push(i); in producer()
51 boost::sync_queue<int> & sbq) in consumer() argument
58 sbq.pull(r); in consumer()
74 void consumer2(the_ostream &/*mos*/, boost::sync_queue<int> & sbq) in consumer2() argument
81 queue_op_status st = sbq.try_pull(r); in consumer2()
94 void consumer3(the_ostream &/*mos*/, boost::sync_queue<int> & sbq) in consumer3() argument
101 queue_op_status res = sbq.wait_pull(r); in consumer3()
129 sync_queue<int> sbq; in main() local
133 scoped_thread<> t11(boost::thread(producer, boost::ref(mcerr), boost::ref(sbq))); in main()
[all …]
|
| D | producer_consumer_bounded.cpp | 30 void producer(the_ostream &/*mos*/, boost::sync_bounded_queue<int> & sbq) in producer() argument
36 sbq.push_back(i); in producer()
52 void consumer(the_ostream &/*mos*/, boost::sync_bounded_queue<int> & sbq) in consumer() argument
59 sbq.pull_front(r); in consumer()
74 void consumer2(the_ostream &/*mos*/, boost::sync_bounded_queue<int> & sbq) in consumer2() argument
81 queue_op_status st = sbq.try_pull_front(r); in consumer2()
129 sync_bounded_queue<int> sbq(10); in main() local
133 scoped_thread<> t11(boost::thread(producer, boost::ref(mcerr), boost::ref(sbq))); in main()
134 scoped_thread<> t12(boost::thread(producer, boost::ref(mcerr), boost::ref(sbq))); in main()
135 scoped_thread<> t2(boost::thread(consumer, boost::ref(mcout), boost::ref(sbq))); in main()
[all …]
|
| /third_party/boost/boost/thread/concurrent_queues/ |
| D | sync_deque.hpp | 298 …sync_deque<ValueType, Container>& operator<<(sync_deque<ValueType, Container>& sbq, BOOST_THREAD_R… in operator <<() argument
300 sbq.push_back(boost::move(elem)); in operator <<()
301 return sbq; in operator <<()
305 …sync_deque<ValueType, Container>& operator<<(sync_deque<ValueType, Container>& sbq, ValueType cons… in operator <<() argument
307 sbq.push_back(elem); in operator <<()
308 return sbq; in operator <<()
312 …sync_deque<ValueType, Container>& operator>>(sync_deque<ValueType, Container>& sbq, ValueType &ele… in operator >>() argument
314 sbq.pull_front(elem); in operator >>()
315 return sbq; in operator >>()
|
| D | sync_queue.hpp | 298 …sync_queue<ValueType, Container>& operator<<(sync_queue<ValueType, Container>& sbq, BOOST_THREAD_R… in operator <<() argument
300 sbq.push(boost::move(elem)); in operator <<()
301 return sbq; in operator <<()
305 …sync_queue<ValueType, Container>& operator<<(sync_queue<ValueType, Container>& sbq, ValueType cons… in operator <<() argument
307 sbq.push(elem); in operator <<()
308 return sbq; in operator <<()
312 …sync_queue<ValueType, Container>& operator>>(sync_queue<ValueType, Container>& sbq, ValueType &ele… in operator >>() argument
314 sbq.pull(elem); in operator >>()
315 return sbq; in operator >>()
|
| D | sync_bounded_queue.hpp | 701 …sync_bounded_queue<ValueType>& operator<<(sync_bounded_queue<ValueType>& sbq, BOOST_THREAD_RV_REF(… in operator <<() argument
703 sbq.push_back(boost::move(elem)); in operator <<()
704 return sbq; in operator <<()
708 …sync_bounded_queue<ValueType>& operator<<(sync_bounded_queue<ValueType>& sbq, ValueType const&elem) in operator <<() argument
710 sbq.push_back(elem); in operator <<()
711 return sbq; in operator <<()
715 sync_bounded_queue<ValueType>& operator>>(sync_bounded_queue<ValueType>& sbq, ValueType &elem) in operator >>() argument
717 sbq.pull_front(elem); in operator >>()
718 return sbq; in operator >>()
|
| /third_party/boost/libs/thread/doc/ |
| D | sync_queues_ref.qbk | 835 sync_bounded_queue<ValueType>& operator<<(sync_bounded_queue<ValueType>& sbq, ValueType&& elem);
837 …sync_bounded_queue<ValueType>& operator<<(sync_bounded_queue<ValueType>& sbq, ValueType const&elem…
839 sync_bounded_queue<ValueType>& operator>>(sync_bounded_queue<ValueType>& sbq, ValueType &elem);
942 sync_bounded_queue<ValueType>& operator<<(sync_bounded_queue<ValueType>& sbq, ValueType&& elem);
944 …sync_bounded_queue<ValueType>& operator<<(sync_bounded_queue<ValueType>& sbq, ValueType const&elem…
955 sync_bounded_queue<ValueType>& operator>>(sync_bounded_queue<ValueType>& sbq, ValueType &elem);
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);
1082 sync_queue<ValueType>& operator<<(sync_queue<ValueType>& sbq, ValueType&& elem);
[all …]
|