Searched refs:THREAD_COUNT (Results 1 – 6 of 6) sorted by relevance
33 for (int i = 0; i < THREAD_COUNT; i++) { in CommonPool()69 if (mWaitingThreads == THREAD_COUNT || (mWaitingThreads > 0 && mWorkQueue.size() > 1)) { in enqueue()99 while (mWaitingThreads != THREAD_COUNT) { in doWaitForIdle()
80 static constexpr auto THREAD_COUNT = 2; variable
53 EXPECT_EQ(threads.size(), CommonPool::THREAD_COUNT); in TEST()104 static constexpr auto QUEUE_COUNT = CommonPool::THREAD_COUNT + CommonPool::QUEUE_SIZE + 10; in TEST()
128 final int THREAD_COUNT = 16; in testTimestampConcurrentParsing() local134 for (int i = 0; i < THREAD_COUNT; i++) { in testTimestampConcurrentParsing()
110 const uint32_t THREAD_COUNT = ctx->getThreadCount(); in setupGEMM() local117 if (nn * kk > MIN_SIZE_TO_TILE && nn * THREAD_COUNT > mm) { in setupGEMM()118 tileSizeN = rsMin(nn / THREAD_COUNT, MAX_WORK_PER_THREAD); in setupGEMM()120 if (mm * kk > MIN_SIZE_TO_TILE && mm * THREAD_COUNT > nn) { in setupGEMM()121 tileSizeM = rsMin(mm / THREAD_COUNT, MAX_WORK_PER_THREAD); in setupGEMM()
174 private static final AtomicInteger THREAD_COUNT = new AtomicInteger(); field in KeyValueBackupTask228 Thread thread = new Thread(task, "key-value-backup-" + THREAD_COUNT.incrementAndGet()); in start()