Lines Matching refs:sbq
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()
137 … scoped_thread<> t12(boost::thread(producer, boost::ref(mcerr), concurrent::queue_back<int>(sbq))); in main()
138 … scoped_thread<> t2(boost::thread(consumer, boost::ref(mcout), concurrent::queue_front<int>(sbq))); in main()
143 sbq.close(); in main()