Lines Matching refs:asyncActivity
172 AsyncActivity asyncActivity(4); in TestNestedArena() local
184 …OutermostArenaBody outer_arena_body(asyncActivity, outermost_arena, innermost_arena, innermost_are… in TestNestedArena()
307 AsyncActivity asyncActivity(4); in TestCleanupMaster() local
316 utils::NativeParallelFor(N, [&asyncActivity, &tg, &iter_spawned, &iter_executed](int j) { in TestCleanupMaster()
318 tg.run([&asyncActivity, j, &iter_executed] { in TestCleanupMaster()
320 tbb::task::suspend(SuspendBody(asyncActivity, std::this_thread::get_id())); in TestCleanupMaster()
332 AsyncActivity& asyncActivity; member in ParForSuspendBody
335 ParForSuspendBody(AsyncActivity& a_, int iters) : asyncActivity(a_), m_numIters(iters) {} in ParForSuspendBody()
338 tbb::task::suspend(SuspendBody(asyncActivity, std::this_thread::get_id())); in operator ()()
343 AsyncActivity asyncActivity(4); in TestNativeThread() local
348 … utils::NativeParallelFor(arena.max_concurrency() / 2, [&arena, &tg, &asyncActivity, &iter](int) { in TestNativeThread()
350 arena.execute([&tg, &asyncActivity, &iter]() { in TestNativeThread()
351 tg.run([&asyncActivity]() { in TestNativeThread()
352 tbb::task::suspend(SuspendBody(asyncActivity, std::this_thread::get_id())); in TestNativeThread()