Lines Matching refs:tg
189 task_group_type tg; in operator ()() local
190 tg.run_and_wait([&] { m_pImpl->Run(idx); }); in operator ()()
200 …cronizationTestBody(utils::SpinBarrier& barrier, std::atomic<bool>& completed, task_group_type& tg) in RunAndWaitSyncronizationTestBody() argument
201 : m_barrier(barrier), m_completed(completed), m_tg(tg) {} in RunAndWaitSyncronizationTestBody()
232 task_group_type tg; in TestParallelWait() local
233 RunAndWaitSyncronizationTestBody<task_group_type> b(barrier, completed, tg); in TestParallelWait()
314 task_group_type tg; in impl() local
315 tg.run( FibTaskAsymmetricTreeWithFunctor(&x, this->m_Num-1) ); in impl()
316 this->m_Num -= 2; tg.run_and_wait( *this ); in impl()
328 task_group_type tg; in impl() local
329 tg.run( FibTaskSymmetricTreeWithFunctor(&x, this->m_Num-1) ); in impl()
330 tg.run( FibTaskSymmetricTreeWithFunctor(&y, this->m_Num-2) ); in impl()
331 tg.wait(); in impl()
363 task_group_type tg; in TestFibWithLambdas() local
365 tg.run( [&](){sum += RunFibTask<FibTaskSymmetricTreeWithFunctor<task_group_type> >(N);} ); in TestFibWithLambdas()
366 tg.wait(); in TestFibWithLambdas()
380 task_group_type tg; in TestFibWithFunctionPtr() local
382 tg.run( &FibFunctionNoArgs<FibTaskSymmetricTreeWithFunctor<task_group_type> > ); in TestFibWithFunctionPtr()
383 tg.wait(); in TestFibWithFunctionPtr()
487 task_group_type tg; in TestManualCancellationWithFunctor() local
491 auto h = tg.defer(&LaunchChildrenWithFunctor<task_group_type>); in TestManualCancellationWithFunctor()
492 tg.run(std::move(h)); in TestManualCancellationWithFunctor()
495 tg.run(&LaunchChildrenWithFunctor<task_group_type>); in TestManualCancellationWithFunctor()
501 tg.cancel(); in TestManualCancellationWithFunctor()
503 tbb::task_group_status status = tg.wait(); in TestManualCancellationWithFunctor()
514 task_group_type tg; in TestExceptionHandling1() local
517 tg.run( &LaunchChildrenWithFunctor<task_group_type> ); in TestExceptionHandling1()
519 tg.wait(); in TestExceptionHandling1()
530 task_group_type tg; in TestExceptionHandling2() local
534 tg.run( &LaunchChildrenWithFunctor<task_group_type> ); in TestExceptionHandling2()
537 tg.wait(); in TestExceptionHandling2()
551 task_group_type tg; in TestExceptionHandling3() local
553 tg.run_and_wait([]() { in TestExceptionHandling3()
569 void Launch(task_group_type& tg) { in Launch() argument
572 tg.run(LaunchChildrenWithFunctor<task_group_type>); in Launch()
592 task_group_type tg; in TestMissingWait() local
593 driver.Launch( tg ); in TestMissingWait()
670 task_group_type tg; in TestBareFunctors() local
673 tg.run_and_wait( NoMoveNoCopyFunctor() ); in TestBareFunctors()
675 tg.run( MoveOnlyFunctor() ); in TestBareFunctors()
676 tg.wait(); in TestBareFunctors()
678 tg.run( mpf ); in TestBareFunctors()
679 tg.wait(); in TestBareFunctors()
683 tg.run( std::move(mpf) ); in TestBareFunctors()
684 tg.wait(); in TestBareFunctors()
714 task_group_type& tg, in ParForBody() argument
717 ) : m_tg(tg), m_preserved(preserved), m_ets(ets) {} in ParForBody()
733 task_group_type tg; in CheckIsolation() local
738 tbb::parallel_for(0, 100, ParForBody<task_group_type>(tg, isolation_is_preserved, ets)); in CheckIsolation()
997 tbb::task_group tg[2]; variable
1001 a.enqueue([i, &tg, &finished, &barrier] { in __anoneb262a490f02()
1004 tg[i].run([] {}); in __anoneb262a490f02()
1012 a.execute([idx, &tg, &finished] { in __anoneb262a491102()
1015 tg[idx%2].wait(); in __anoneb262a491102()
1018 tg[idx%2].wait(); in __anoneb262a491102()
1038 tbb::task_group tg; variable
1039 SelfRunner uf{tg, count};
1040 tg.run( uf );
1041 tg.wait();
1135 tbb::task_group tg; variable
1138 tg.run([&]{ in __anoneb262a491c02()
1139 return tg.defer([&]{ in __anoneb262a491c02()
1144 tg.wait();
1151 tbb::task_group tg; variable
1154 tg.run_and_wait([&]{ in __anoneb262a491e02()
1155 return tg.defer([&]{ in __anoneb262a491e02()
1173 tbb::task_group tg; in should_fail() local
1175 …CHECK_THROWS_WITH_AS(tg.run(tbb::task_handle{}), "Attempt to schedule empty task_handle", std::run… in should_fail()
1184 tbb::task_group tg; in should_fail() local
1187 …CHECK_THROWS_WITH_AS(tg1.run(tg.defer([]{})), "Attempt to schedule task_handle into different task… in should_fail()
1199 tbb::task_group tg(ctx); in should_fail() local
1202 CHECK_NOTHROW(tg.run(tg.defer([]{}))); in should_fail()
1203 …CHECK_THROWS_WITH_AS(tg1.run(tg.defer([]{})), "Attempt to schedule task_handle into different task… in should_fail()