Lines Matching refs:ProducerConsumerQueue

212 ProducerConsumerQueue Q(INT_MAX);
502 ProducerConsumerQueue Q(INT_MAX);
603 ProducerConsumerQueue Q1(INT_MAX), Q2(INT_MAX);
1103 ProducerConsumerQueue Q(INT_MAX);
1140 ProducerConsumerQueue *Q1, *Q2;
1144 void Putter(ProducerConsumerQueue *q) {  in Putter()
1171   Q1 = new ProducerConsumerQueue(INT_MAX);  in Run()
1172   Q2 = new ProducerConsumerQueue(INT_MAX);  in Run()
1520 ProducerConsumerQueue Q(INT_MAX);
1617 ProducerConsumerQueue *Q1, *Q2;
1621 void Putter(ProducerConsumerQueue *q) {  in Putter()
1654   Q1 = new ProducerConsumerQueue(INT_MAX);  in Run()
1655   Q2 = new ProducerConsumerQueue(INT_MAX);  in Run()
1720 ProducerConsumerQueue *Q1, *Q2;
1724 void Putter(ProducerConsumerQueue *q) {  in Putter()
1758   Q1 = new ProducerConsumerQueue(INT_MAX);  in Run()
1759   Q2 = new ProducerConsumerQueue(INT_MAX);  in Run()
1849 ProducerConsumerQueue Q(INT_MAX);
1885 ProducerConsumerQueue Q(INT_MAX);
1926 ProducerConsumerQueue Q(INT_MAX);
2694 ProducerConsumerQueue Q(INT_MAX);
2763 ProducerConsumerQueue Q(INT_MAX);
2812 ProducerConsumerQueue Q(INT_MAX);
3973 ProducerConsumerQueue Q(INT_MAX);  // Used to pass A* between threads.
5828 ProducerConsumerQueue q(10);
7059 ProducerConsumerQueue *Q[N_threads];
7066    ProducerConsumerQueue &myQ = *Q[myId], &nextQ = *Q[(myId+1) % N_threads];  in Worker()
7085       Q[i] = new ProducerConsumerQueue(1);  in Run()