Lines Matching refs:ConcurrencyTracker
67 while ( utils::ConcurrencyTracker::PeakParallelism() < m_pOwner->m_numThreads ) in operator ()()
79 utils::ConcurrencyTracker ct; in Spawn()
95 …INFO("Max spawning parallelism is " << utils::ConcurrencyTracker::PeakParallelism() << "out of " <… in Wait()
97 m_barrier.wait( &utils::ConcurrencyTracker::Reset ); in Wait()
99 utils::ConcurrencyTracker ct; in Wait()
102 if ( utils::ConcurrencyTracker::PeakParallelism() == 1 ) { in Wait()
125 utils::ConcurrencyTracker::Reset(); in SharedGroupBodyImpl()
280 utils::ConcurrencyTracker::Reset()
283 CHECK(utils::ConcurrencyTracker::PeakParallelism() <= g_MaxConcurrency); \
297 utils::ConcurrencyTracker ct; in operator ()()
425 utils::ConcurrencyTracker ct; in operator ()()
445 utils::ConcurrencyTracker::Reset(); in ResetGlobals()
507 …CHECK_MESSAGE( g_TaskCount <= g_ExecutedAtCancellation + utils::ConcurrencyTracker::PeakParallelis… in TestManualCancellationWithFunctor()