Lines Matching refs:task_arena

61                 tbb::task_arena arena( std::rand() % maxthread + 1 );  in InitializeAndTerminate()
70 tbb::task_arena arena( 1 ); in InitializeAndTerminate()
77 tbb::task_arena arena( tbb::task_arena::automatic ); in InitializeAndTerminate()
84 tbb::task_arena arena; in InitializeAndTerminate()
134 ArenaObserver(tbb::task_arena &a, int maxConcurrency, int numReservedSlots, int id) in ArenaObserver()
177 LocalObserver(tbb::task_arena& a) : tbb::task_scheduler_observer(a) { in TestConcurrentArenasFunc()
185 tbb::task_arena a1; in TestConcurrentArenasFunc()
190 tbb::task_arena a2(2,1); in TestConcurrentArenasFunc()
197 tbb::task_arena a3(1, 0); in TestConcurrentArenasFunc()
226 tbb::task_arena &my_a;
229 MultipleMastersPart1( tbb::task_arena &a, utils::SpinBarrier &b1, utils::SpinBarrier &b2) in MultipleMastersPart1()
240 tbb::task_arena &my_a;
243 MultipleMastersPart2( tbb::task_arena &a, utils::SpinBarrier &b) : my_a(a), my_b(b) {} in MultipleMastersPart2()
250 tbb::task_arena &my_a;
273 MultipleMastersPart3(tbb::task_arena &a, utils::SpinBarrier &b) in MultipleMastersPart3()
290 tbb::task_arena a(1,0); in TestMultipleMasters()
299 tbb::task_arena a(2,1); in TestMultipleMasters()
310 tbb::task_arena a(p,1); in TestMultipleMasters()
373 tbb::task_arena &my_a; // expected task_arena(2,1)
378 ForEachArenaEntryBody(tbb::task_arena &a, std::atomic<int> &c) in ForEachArenaEntryBody()
420 tbb::task_arena a(2, 1); in TestArenaEntryConsistency()
434 tbb::task_arena &my_a;
440 …TestArenaConcurrencyBody( tbb::task_arena &a, int max_concurrency, int reserved_slots, utils::Spin… in TestArenaConcurrencyBody()
473 tbb::task_arena a( p, reserved ); in TestArenaConcurrency()
513 TestMandatoryConcurrencyObserver(tbb::task_arena& a, utils::SpinBarrier& barrier) in TestMandatoryConcurrencyObserver()
528 tbb::task_arena a(1); in TestMandatoryConcurrency()
576 const tbb::task_arena& my_arena;
577 TaskArenaValidator( const tbb::task_arena& other ) in TaskArenaValidator()
593 void ValidateAttachedArena( tbb::task_arena& arena, bool expect_activated, in ValidateAttachedArena()
600 if ( tbb::this_task_arena::current_thread_index() != tbb::task_arena::not_initialized ) { in ValidateAttachedArena()
625 tbb::task_arena arena{tbb::task_arena::attach()}; in operator ()()
634 tbb::task_arena arena2{tbb::task_arena::attach()}; in operator ()()
637 tbb::task_arena arena3; in operator ()()
649 tbb::task_arena arena2{tbb::task_arena::attach()}; in operator ()()
656 tbb::task_arena arena2{tbb::task_arena::attach()}; in operator ()()
681 tbb::task_arena a; in TestConstantFunctorRequirement()
937 tbb::task_arena& arena;
940 …b::enumerable_thread_specific<bool>& exe, std::atomic<int>& c, wait_context& w, tbb::task_arena& a) in TestEnqueueTask()
960 tbb::task_arena& arena;
964 …eueIsolateBody(tbb::enumerable_thread_specific<bool>& exe, std::atomic<int>& c, tbb::task_arena& a) in TestEnqueueIsolateBody()
978 tbb::task_arena arena{tbb::task_arena::attach()}; in TestEnqueue()
1035 tbb::task_arena &my_a;
1038 TestDelegatedSpawnWaitBody( tbb::task_arena &a, utils::SpinBarrier &b1, utils::SpinBarrier &b2) in TestDelegatedSpawnWaitBody()
1064 tbb::task_arena a(2,0); in TestDelegatedSpawnWait()
1101 …TestMultipleWaitsThreadBody( int bunch_size, int num_tasks, tbb::task_arena& a, std::vector<wait_c… in TestMultipleWaitsThreadBody()
1110 tbb::task_arena& my_arena;
1117 tbb::task_arena a( num_threads ); in TestMultipleWaits()
1171 tbb::task_arena a; in TestSmallStackSize()
1202 tbb::task_arena ta; in TestFunctors()
1281 tbb::task_arena& arena() { in arena()
1282 static tbb::task_arena a; in arena()
1340 tbb::enumerable_thread_specific<tbb::task_arena*>& my_tls;
1341 tbb::task_arena& my_arena;
1346 MyObserver(tbb::task_arena& a, in MyObserver()
1347 tbb::enumerable_thread_specific<tbb::task_arena*>& tls, in MyObserver()
1361 tbb::task_arena*& cur_arena = my_tls.local(); in on_scheduler_entry()
1405 std::vector<tbb::task_arena> arenas(n_arenas); in TestArenaWorkersMigrationWithNumThreads()
1408 tbb::enumerable_thread_specific<tbb::task_arena*> tls; in TestArenaWorkersMigrationWithNumThreads()
1515 tbb::task_arena test_arena(arena_concurrency, arena_concurrency); in ExceptionInExecute()
1558 simple_observer(tbb::task_arena &a, int maxConcurrency, int numReservedSlots) in simple_observer()
1583 tbb::task_arena* arena;
1590 arena_handler(tbb::task_arena* ptr) : arena(ptr) in arena_handler()
1650 arenas_pool.emplace(new tbb::task_arena()); in StressTestMixFunctionality()
1656 arenas_pool.emplace(new tbb::task_arena()); in StressTestMixFunctionality()
1751 …enqueue_test_helper(tbb::task_arena& arena, tbb::enumerable_thread_specific<bool>& ets , std::atom… in enqueue_test_helper()
1764 tbb::task_arena& my_arena;
1770 tbb::task_arena a(concurrency, reserved_slots); in test_threads_sleep()
1814 …REQUIRE_MESSAGE((tbb::this_task_arena::current_thread_index() == tbb::task_arena::not_initialized)…
1817 tbb::task_arena arena(int(utils::get_platform_max_threads() * 2));
1929 tbb::task_arena arena;
1949 tbb::task_arena arena(static_cast<int>(num_threads) * 2);
1988 tbb::task_arena ta; in should_fail()
2027 tbb::task_arena arena;
2040 tbb::task_arena arena;
2053 std::vector<tbb::task_arena> arenas(42);