Lines Matching defs:consumers
88 /* Feed back rest of messages to buffer (they are end messages) so other consumers wake up. */
172 vector<Consumer*> consumers;
178 consumers.push_back(new Consumer(buffer, numProducers));
180 // Start consumers.
181 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++)
192 // Write end messages for consumers.
198 // Wait for consumers.
199 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++)
211 cmpSum += consumers[j]->getPayloadSum(i);
218 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++)
