Searched refs:THREAD_COUNT (Results 1 – 7 of 7) 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
38 for (int i = 0; i < THREAD_COUNT; i++) { in CommonPool()71 if (mWaitingThreads == THREAD_COUNT || (mWaitingThreads > 0 && mWorkQueue.size() > 1)) { in enqueue()
47 static constexpr auto THREAD_COUNT = 2; variable
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()
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()
182 private static final AtomicInteger THREAD_COUNT = new AtomicInteger(); field in KeyValueBackupTask242 Thread thread = new Thread(task, "key-value-backup-" + THREAD_COUNT.incrementAndGet()); in start()