Searched refs:max_concurrency (Results 1 – 9 of 9) sorted by relevance
185 size_t max_concurrency = GetMaxConcurrency(state.worker_count() - 1); in WaitForParticipationOpportunity() local191 while (!((state.worker_count() <= max_concurrency && !state.is_canceled()) || in WaitForParticipationOpportunity()204 max_concurrency = GetMaxConcurrency(state.worker_count() - 1); in WaitForParticipationOpportunity()211 if (state.worker_count() <= max_concurrency && !state.is_canceled()) { in WaitForParticipationOpportunity()217 DCHECK(state.is_canceled() || max_concurrency == 0U); in WaitForParticipationOpportunity()237 const size_t max_concurrency = in WillRunTask() local239 if (state_before_add.worker_count() < max_concurrency) { in WillRunTask()244 if (worker_count_before_add >= max_concurrency) { in WillRunTask()248 DCHECK_LT(worker_count_before_add, max_concurrency); in WillRunTask()249 return max_concurrency == worker_count_before_add + 1 in WillRunTask()[all …]
266 size_t max_concurrency = 1; in TEST_F() local271 [&](JobDelegate* delegate) { --max_concurrency; }), in TEST_F()273 return max_concurrency + worker_count; in TEST_F()287 EXPECT_EQ(0U, max_concurrency); in TEST_F()293 size_t max_concurrency = 1; in TEST_F() local298 [&](JobDelegate* delegate) { --max_concurrency; }), in TEST_F()300 return max_concurrency + worker_count; in TEST_F()308 EXPECT_EQ(0U, max_concurrency); in TEST_F()
756 std::atomic_size_t max_concurrency(1); in TEST_F() local761 [&](size_t /*worker_count*/) -> size_t { return max_concurrency; }), in TEST_F()770 max_concurrency = 0; in TEST_F()
95 auto max_concurrency = nthread - 1; in tex_cacheline_concurr() local97 << max_concurrency * TEXEL_SIZE << std::endl; in tex_cacheline_concurr()
365 _Index __p = tbb::this_task_arena::max_concurrency(); in __parallel_strict_scan()
866 optional int32 max_concurrency = 5; field
11865 ::int32_t max_concurrency() const; in Swap()27570 inline ::int32_t DataSetProto::max_concurrency() const { in max_concurrency() function
12804 ::int32_t max_concurrency() const; in Swap()28795 inline ::int32_t DataSetProto::max_concurrency() const { in max_concurrency() function