Lines Matching refs:arena
61 tbb::task_arena arena( std::rand() % maxthread + 1 ); in InitializeAndTerminate() local
62 CHECK_MESSAGE(!arena.is_active(), "arena should not be active until initialized"); in InitializeAndTerminate()
63 arena.initialize(); in InitializeAndTerminate()
64 CHECK(arena.is_active()); in InitializeAndTerminate()
65 arena.terminate(); in InitializeAndTerminate()
66 CHECK_MESSAGE(!arena.is_active(), "arena should not be active; it was terminated"); in InitializeAndTerminate()
70 tbb::task_arena arena( 1 ); in InitializeAndTerminate() local
71 CHECK_MESSAGE(!arena.is_active(), "arena should not be active until initialized"); in InitializeAndTerminate()
72 arena.initialize( std::rand() % maxthread + 1 ); // change the parameters in InitializeAndTerminate()
73 CHECK(arena.is_active()); in InitializeAndTerminate()
77 tbb::task_arena arena( tbb::task_arena::automatic ); in InitializeAndTerminate() local
78 CHECK(!arena.is_active()); in InitializeAndTerminate()
79 arena.initialize(); in InitializeAndTerminate()
80 CHECK(arena.is_active()); in InitializeAndTerminate()
84 tbb::task_arena arena; in InitializeAndTerminate() local
85 CHECK_MESSAGE(!arena.is_active(), "arena should not be active until initialized"); in InitializeAndTerminate()
86 arena.initialize( std::rand() % maxthread + 1 ); in InitializeAndTerminate()
87 CHECK(arena.is_active()); in InitializeAndTerminate()
88 arena.terminate(); in InitializeAndTerminate()
89 CHECK_MESSAGE(!arena.is_active(), "arena should not be active; it was terminated"); in InitializeAndTerminate()
593 void ValidateAttachedArena( tbb::task_arena& arena, bool expect_activated, in ValidateAttachedArena() argument
595 CHECK_MESSAGE( arena.is_active()==expect_activated, "Unexpected activation state" ); in ValidateAttachedArena()
596 if( arena.is_active() ) { in ValidateAttachedArena()
597 TaskArenaValidator validator( arena ); in ValidateAttachedArena()
603 arena.execute( validator ); in ValidateAttachedArena()
625 tbb::task_arena arena{tbb::task_arena::attach()}; in operator ()() local
626 ValidateAttachedArena( arena, false, -1, -1 ); // Nothing yet to attach to in operator ()()
628 arena.terminate(); in operator ()()
629 ValidateAttachedArena( arena, false, -1, -1 ); in operator ()()
643 arena.initialize( maxthread, std::min(maxthread,idx) ); in operator ()()
644 arena.execute( *this ); in operator ()()
937 tbb::task_arena& arena; member in TestIsolatedExecuteNS::TestEnqueueTask
941 : executed(exe), completed(c), waiter(w), arena(a) {} in TestEnqueueTask()
945 arena.enqueue([&]() { in execute()
960 tbb::task_arena& arena; member in TestIsolatedExecuteNS::TestEnqueueIsolateBody
965 : executed(exe), completed(c), arena(a) {} in TestEnqueueIsolateBody()
970 TestEnqueueTask root(executed, completed, waiter, arena); in operator ()()
978 tbb::task_arena arena{tbb::task_arena::attach()}; in TestEnqueue() local
982 TestEnqueueIsolateBody b1(executed, completed, arena); in TestEnqueue()
997 arena.enqueue([&]() { in TestEnqueue()
1004 TestEnqueueIsolateBody b2(executed, completed, arena); in TestEnqueue()
1281 tbb::task_arena& arena() { in arena() function
1289 ReturnType r{arena().execute(f)}; in TestExecute()
1296 ReturnType r{arena().execute(f)}; in TestExecute()
1319 arena().execute(Functor<void>()); in Test()
1321 arena().execute(f2); in Test()
1322 arena().execute(function<void>); in Test()
1583 tbb::task_arena* arena; member
1590 arena_handler(tbb::task_arena* ptr) : arena(ptr) in arena_handler()
1594 return lhs.arena < rhs.arena; in operator <()
1673 delete curr_arena->arena; in StressTestMixFunctionality()
1684 curr_arena->observers.emplace(*curr_arena->arena, thread_number, 1); in StressTestMixFunctionality()
1709 curr_arena->arena->execute([]() { in StressTestMixFunctionality()
1724 curr_arena->arena->enqueue([] { utils::doDummyWork(1000); }); in StressTestMixFunctionality()
1746 if (handler.status != arena_handler::deleted) delete handler.arena; in StressTestMixFunctionality()
1751 …enqueue_test_helper(tbb::task_arena& arena, tbb::enumerable_thread_specific<bool>& ets , std::atom… in enqueue_test_helper()
1752 : my_arena(arena), my_ets(ets), my_task_counter(task_counter) in enqueue_test_helper()
1817 tbb::task_arena arena(int(utils::get_platform_max_threads() * 2));
1818 arena.execute([&ets] { in __anon1d1198c31c02()
1929 tbb::task_arena arena; variable
1932 arena.execute([] { in __anon1d1198c31e02()
1949 tbb::task_arena arena(static_cast<int>(num_threads) * 2);
1953 arena.execute([&] { in __anon1d1198c32002()
1966 arena.enqueue(enqueue_test_helper(arena, ets, task_counter));
1971 arena.execute([&] { in __anon1d1198c32202()
2027 tbb::task_arena arena; variable
2029 arena.execute([&]{ in __anon1d1198c32502()
2040 tbb::task_arena arena; variable
2043 arena.execute([&] { in __anon1d1198c32602()
2054 for (auto& arena : arenas) { variable
2055 arena.initialize(1, 0);
2059 for (auto& arena : arenas) { variable
2060 arena.enqueue([&] { in __anon1d1198c32802()