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) {  in Putter()
1483   Q1 = new ProducerConsumerQueue(INT_MAX);  in Run()
1484   Q2 = new ProducerConsumerQueue(INT_MAX);  in Run()
1834 ProducerConsumerQueue Q(INT_MAX);
1931 ProducerConsumerQueue *Q1, *Q2;
1935 void Putter(ProducerConsumerQueue *q) {  in Putter()
1968   Q1 = new ProducerConsumerQueue(INT_MAX);  in Run()
1969   Q2 = new ProducerConsumerQueue(INT_MAX);  in Run()
2037 ProducerConsumerQueue *Q1, *Q2;
2041 void Putter(ProducerConsumerQueue *q) {  in Putter()
2075   Q1 = new ProducerConsumerQueue(INT_MAX);  in Run()
2076   Q2 = new ProducerConsumerQueue(INT_MAX);  in Run()
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];  in Worker()
7423       Q[i] = new ProducerConsumerQueue(1);  in Run()