Lines Matching refs:g_MaxConcurrency
32 unsigned g_MaxConcurrency = 4; variable
95 …parallelism is " << utils::ConcurrencyTracker::PeakParallelism() << "out of " << g_MaxConcurrency); in Wait()
222 NativeParallelFor( g_MaxConcurrency, SharedGroupBody<task_group_type>(g_MaxConcurrency) ); in TestParallelSpawn()
227 …NativeParallelFor( g_MaxConcurrency, SharedGroupBody<task_group_type>(g_MaxConcurrency, ParallelWa… in TestParallelWait()
229 utils::SpinBarrier barrier(g_MaxConcurrency); in TestParallelWait()
234 NativeParallelFor( g_MaxConcurrency, b ); in TestParallelWait()
279 const unsigned numRepeats = g_MaxConcurrency * 4; \
283 CHECK(utils::ConcurrencyTracker::PeakParallelism() <= g_MaxConcurrency); \
499 while ( g_MaxConcurrency > 1 && g_TaskCount == 0 ) in TestManualCancellationWithFunctor()
575 while (g_MaxConcurrency > 1 && g_TaskCount == 0) in Launch()
582 …CHECK_MESSAGE(g_TaskCount <= g_ExecutedAtCancellation + g_MaxConcurrency, "Too many tasks survived… in Finish()
772 g_MaxConcurrency = p;
783 g_MaxConcurrency = p;
794 g_MaxConcurrency = p;
806 g_MaxConcurrency = p;
816 g_MaxConcurrency = p;
840 g_MaxConcurrency = p;
851 g_MaxConcurrency = p;
861 g_MaxConcurrency = p;
871 g_MaxConcurrency = p;
881 g_MaxConcurrency = p;