Lines Matching defs:consumers
135 vector<Consumer*> consumers;
141 consumers.push_back(new Consumer(buffer, numProducers));
143 // Start consumers.
144 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++)
155 // Write end messages for consumers.
159 // Wait for consumers.
160 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++)
172 cmpSum += consumers[j]->getPayloadSum(i);
179 for (vector<Consumer*>::iterator i = consumers.begin(); i != consumers.end(); i++)
