Searched refs:THREAD_COUNT (Results 1 – 5 of 5) sorted by relevance
33 std::vector<int> tids(THREAD_COUNT); in CommonPool()34 std::vector<std::condition_variable> tidConditionVars(THREAD_COUNT); in CommonPool()37 for (int i = 0; i < THREAD_COUNT; i++) { in CommonPool()61 for (int i = 0; i < THREAD_COUNT; i++) { in CommonPool()91 if (mWaitingThreads == THREAD_COUNT || (mWaitingThreads > 0 && mWorkQueue.size() > 1)) { in enqueue()121 while (mWaitingThreads != THREAD_COUNT) { in doWaitForIdle()
81 static constexpr auto THREAD_COUNT = 2; variable
53 static int THREAD_COUNT = getThreadCount(); in TEST() local61 for (int i = 0; i < THREAD_COUNT; ++i) { in TEST()
53 EXPECT_EQ(threads.size(), CommonPool::THREAD_COUNT); in TEST()106 static constexpr auto QUEUE_COUNT = CommonPool::THREAD_COUNT + CommonPool::QUEUE_SIZE + 10; in TEST()
183 private static final AtomicInteger THREAD_COUNT = new AtomicInteger(); field in KeyValueBackupTask244 Thread thread = new Thread(task, "key-value-backup-" + THREAD_COUNT.incrementAndGet()); in start()