Lines Matching refs:sbq
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()
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()
140 sbq.close(); in main()