Lines Matching refs:ProducerConsumerQueue
452 ProducerConsumerQueue Q(INT_MAX);
798 ProducerConsumerQueue Q(INT_MAX);
899 ProducerConsumerQueue Q1(INT_MAX), Q2(INT_MAX);
1411 ProducerConsumerQueue Q(INT_MAX);
1448 ProducerConsumerQueue *Q1, *Q2;
1452 void Putter(ProducerConsumerQueue *q) {
1479 Q1 = new ProducerConsumerQueue(INT_MAX);
1480 Q2 = new ProducerConsumerQueue(INT_MAX);
1830 ProducerConsumerQueue Q(INT_MAX);
1927 ProducerConsumerQueue *Q1, *Q2;
1931 void Putter(ProducerConsumerQueue *q) {
1964 Q1 = new ProducerConsumerQueue(INT_MAX);
1965 Q2 = new ProducerConsumerQueue(INT_MAX);
2033 ProducerConsumerQueue *Q1, *Q2;
2037 void Putter(ProducerConsumerQueue *q) {
2071 Q1 = new ProducerConsumerQueue(INT_MAX);
2072 Q2 = new ProducerConsumerQueue(INT_MAX);
2162 ProducerConsumerQueue Q(INT_MAX);
2198 ProducerConsumerQueue Q(INT_MAX);
2239 ProducerConsumerQueue Q(INT_MAX);
3018 ProducerConsumerQueue Q(INT_MAX);
3087 ProducerConsumerQueue Q(INT_MAX);
3137 ProducerConsumerQueue Q(INT_MAX);
4168 ProducerConsumerQueue Q(INT_MAX); // Used to pass A* between threads.
4241 ProducerConsumerQueue Q(INT_MAX); // Used to pass A* between threads.
6345 ProducerConsumerQueue q(10);
7393 ProducerConsumerQueue *Q[N_threads];
7400 ProducerConsumerQueue &myQ = *Q[myId], &nextQ = *Q[(myId+1) % N_threads];
7419 Q[i] = new ProducerConsumerQueue(1);