Lines Matching refs:threads
91 Semaphore taskSemaphore; // threads wait on this for ready tasks
98 Mutex threadMutex; // mutual exclusion for threads list
99 list<WorkerThread*> threads; // the list of all threads
102 bool stopping; // flag indicating whether to stop threads
233 // Signal enough times to allow all threads to stop.
235 // Wait until all threads have started their run functions.
236 // If we do not wait before we destroy the threads then it's
237 // possible that the threads have not yet called their run
251 // Join all the threads
254 for (list<WorkerThread*>::iterator i = threads.begin();
255 i != threads.end();
263 threads.clear();
352 throw Iex::ArgExc ("Attempt to set the number of threads "
364 // Add more threads
369 _data->threads.push_back (new WorkerThread (_data));
376 // Wait until all existing threads are finished processing,
377 // then delete all threads.
383 // Add in new threads
388 _data->threads.push_back (new WorkerThread (_data));
399 // Lock the threads, needed to access numThreads
