Lines Matching refs:threads
889 void createThreads (vector<TestThread*>& threads, int threadCount, int perThreadContextCount, vector<TestContext*>& contexts)
892 DE_ASSERT(threads.empty());
901 threads.push_back(new TestThread(threadContexts));
907 void destroyThreads (vector<TestThread*>& threads)
909 for (int threadNdx = 0; threadNdx < (int)threads.size(); threadNdx++)
911 delete threads[threadNdx];
912 threads[threadNdx] = DE_NULL;
915 threads.clear();
918 void startThreads (vector<TestThread*>& threads)
920 for (int threadNdx = 0; threadNdx < (int)threads.size(); threadNdx++)
921 threads[threadNdx]->start();
924 void joinThreads (vector<TestThread*>& threads)
926 for (int threadNdx = 0; threadNdx < (int)threads.size(); threadNdx++)
927 threads[threadNdx]->join();
930 bool threadResultsOk (const vector<TestThread*>& threads)
932 for (int threadNdx = 0; threadNdx < (int)threads.size(); threadNdx++)
934 if (!threads[threadNdx]->resultOk())
992 log << TestLog::Message << "Number of threads: " << config.threadCount << TestLog::EndMessage;
1041 vector<TestThread*> threads;
1046 createThreads(threads, m_config.threadCount, m_config.perThreadContextCount, m_contexts);
1050 startThreads(threads);
1051 joinThreads(threads);
1055 if (!threadResultsOk(threads))
1061 destroyThreads(threads);
1074 string createTestName(int threads, int perThreadContextCount)
1078 stream << threads << (threads == 1 ? "_thread_" : "_threads_") << perThreadContextCount << (perThreadContextCount == 1 ? "_context" : "_contexts");
