Lines Matching refs:ProducerConsumerQueue
456 ProducerConsumerQueue Q(INT_MAX);
802 ProducerConsumerQueue Q(INT_MAX);
903 ProducerConsumerQueue Q1(INT_MAX), Q2(INT_MAX);
1415 ProducerConsumerQueue Q(INT_MAX);
1452 ProducerConsumerQueue *Q1, *Q2;
1456 void Putter(ProducerConsumerQueue *q) {
1483 Q1 = new ProducerConsumerQueue(INT_MAX);
1484 Q2 = new ProducerConsumerQueue(INT_MAX);
1834 ProducerConsumerQueue Q(INT_MAX);
1931 ProducerConsumerQueue *Q1, *Q2;
1935 void Putter(ProducerConsumerQueue *q) {
1968 ProducerConsumerQueue(INT_MAX);
1969 Q2 = new ProducerConsumerQueue(INT_MAX);
2037 ProducerConsumerQueue *Q1, *Q2;
2041 void Putter(ProducerConsumerQueue *q) {
2075 Q1 = new ProducerConsumerQueue(INT_MAX);
2076 Q2 = new ProducerConsumerQueue(INT_MAX);
2166 ProducerConsumerQueue Q(INT_MAX);
2202 ProducerConsumerQueue Q(INT_MAX);
2243 ProducerConsumerQueue Q(INT_MAX);
3022 ProducerConsumerQueue Q(INT_MAX);
3091 ProducerConsumerQueue Q(INT_MAX);
3141 ProducerConsumerQueue Q(INT_MAX);
4172 ProducerConsumerQueue Q(INT_MAX); // Used to pass A* between threads.
4245 ProducerConsumerQueue Q(INT_MAX); // Used to pass A* between threads.
6349 ProducerConsumerQueue q(10);
7397 ProducerConsumerQueue *Q[N_threads];
7404 ProducerConsumerQueue &myQ = *Q[myId], &nextQ = *Q[(myId+1) % N_threads];
7423 Q[i] = new ProducerConsumerQueue(1);
