Home
last modified time | relevance | path

Searched refs:tg (Results 1 – 19 of 19) sorted by relevance

/oneTBB/test/tbb/
H A Dtest_task_group.cpp331 tg.wait(); in impl()
366 tg.wait(); in TestFibWithLambdas()
383 tg.wait(); in TestFibWithFunctionPtr()
501 tg.cancel(); in TestManualCancellationWithFunctor()
519 tg.wait(); in TestExceptionHandling1()
537 tg.wait(); in TestExceptionHandling2()
1040 tg.run( uf );
1041 tg.wait();
1138 tg.run([&]{ in __anoneb262a491c02()
1144 tg.wait();
[all …]
H A Dtest_resumable_tasks.cpp308 tbb::task_group tg; 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()
327 tg.wait(); in TestCleanupMaster()
346 tbb::task_group tg; 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()
360 arena.execute([&tg](){ in TestNativeThread()
361 tg.wait(); in TestNativeThread()
H A Dtest_arena_priorities.cpp145 auto& tg = std::get<associated_task_group>(item); in submit_work() local
148 [repeats, &barrier, &tg, priority_value, concurrency]() { in submit_work()
150 tg->run( in submit_work()
173 auto& tg = std::get<associated_task_group>(item); in wait_work_completion() local
174 arena.execute( [&tg]() { tg->wait(); } ); in wait_work_completion()
H A Dtest_global_control.cpp81 tbb::task_group tg; in operator ()() local
83 tg.run( eb ); in operator ()()
84 tg.wait(); in operator ()()
H A Dtest_task_arena.cpp1046 tbb::task_group tg; in operator ()() local
1049 my_a.execute([&tg] { tg.run([] {}); }); in operator ()()
1051 my_a.execute([&tg] {tg.wait(); }); in operator ()()
2016 tbb::task_group tg; variable
2017 tg.run_and_wait([&]{ in __anon1d1198c32402()
2041 tbb::task_group tg; variable
2042 tg.run_and_wait([&] { in __anon1d1198c32602()
H A Dtest_eh_algorithms.cpp1180 tbb::task_group tg; in TestCancelation1_parallel_for_each() local
1184 tg.run( cancellator ); in TestCancelation1_parallel_for_each()
1186 tg.run( worker ); in TestCancelation1_parallel_for_each()
1188 tg.wait(); in TestCancelation1_parallel_for_each()
/oneTBB/test/conformance/
H A Dconformance_task_group.cpp41 auto h = tg.defer([&]{ in __anon0c2008c70102()
53 oneapi::tbb::task_group tg; variable
58 h = tg.defer([&]{ in __anon0c2008c70202()
62 tg.run(std::move(h));
63 tg.wait();
79 h = tg.defer([&]{ in __anon0c2008c70302()
99 h = tg.defer([]{}); in __anon0c2008c70402()
116 h = tg.defer([]{}); in __anon0c2008c70502()
158 tg.wait(); in __anon0c2008c70702()
167 tg.run(std::move(h)); in __anon0c2008c70902()
[all …]
H A Dconformance_task_arena.cpp133 oneapi::tbb::task_group tg; variable
142 tg.wait();
151 oneapi::tbb::task_group tg; variable
163 tg.wait();
175 oneapi::tbb::task_group tg; variable
182 auto task_handle = tg.defer([]{}); in __anon3e0b77410902()
192 tg.wait();
201 oneapi::tbb::task_group tg; variable
204 oneapi::tbb::task_handle h = tg.defer([&]{ in __anon3e0b77410c02()
219 oneapi::tbb::task_group tg; variable
[all …]
H A Dconformance_resumable_tasks.cpp58 oneapi::tbb::task_group tg; variable
60 tg.run([&tg, &suspend, &resume] { in __anon366fea4d0302()
61 … oneapi::tbb::task::suspend([&tg, &suspend, &resume](oneapi::tbb::task::suspend_point sp) { in __anon366fea4d0302()
63 tg.run([sp, &resume] { in __anon366fea4d0302()
70 tg.wait();
H A Dconformance_collaborative_call_once.cpp93 oneapi::tbb::task_group tg; variable
97 tg.run([&flag, &barrier] { in __anon8e61f74e0402()
118 tg.wait();
/oneTBB/doc/main/tbb_userguide/Migration_Guide/
H A DTask_API.rst54 tg.wait();
181 tg.run([&i = items[i], &tg] {
191 tg.wait();
223 tg.run(SharedStateFunctor{data, tg});
224 tg.wait();
255 tg.run(SharedStateFunctor{data, tg});
256 tg.wait();
326 tg.wait();
378 tg.run([&tg](){
384 tg.wait();
[all …]
/oneTBB/examples/migration/recursive_fibonacci/
H A Dtask_emulation_layer.h145 friend F create_root_task(tbb::task_group& tg, Args&&... args);
148 friend F* allocate_root_task(tbb::task_group& tg, Args&&... args);
178 …root_task(tbb::task_group& tg) : m_tg(tg), m_callback(m_tg.defer([] { /* Create empty callback to … in root_task() argument
194 F create_root_task(tbb::task_group& tg, Args&&... args) { in create_root_task() argument
197 obj.reset_parent(new root_task{tg}); in create_root_task()
202 F* allocate_root_task(tbb::task_group& tg, Args&&... args) { in allocate_root_task() argument
205 obj->reset_parent(new root_task{tg}); in allocate_root_task()
220 void run_and_wait(tbb::task_group& tg, F* f) { in run_and_wait() argument
221 tg.run_and_wait(std::ref(*f)); in run_and_wait()
H A Dfibonacci_two_tasks.h73 tbb::task_group tg; in fibonacci_two_tasks() local
74 tg.run_and_wait( in fibonacci_two_tasks()
75 task_emulation::create_root_task<fib_computation>(/* for root task = */ tg, n, &sum)); in fibonacci_two_tasks()
H A Dfibonacci_single_task.h92 tbb::task_group tg; in fibonacci_single_task() local
93 …task_emulation::run_and_wait(tg, task_emulation::allocate_root_task<single_fib_task>(/* for root t… in fibonacci_single_task()
/oneTBB/test/common/
H A Dexception_handling.h233 tbb::task_group tg; in WaitUntilConcurrencyPeaks() local
246 tg.run([]{}); in WaitUntilConcurrencyPeaks()
252 tg.wait(); in WaitUntilConcurrencyPeaks()
306 tbb::task_group tg; variable
311 tg.run(launcher);
312 tg.run(cancellator);
315 tg.wait();
/oneTBB/python/tbb/
H A Dapi.i91 tbb::task_group tg; variable
96 tg.run([&b]{
105 tg.wait();
/oneTBB/examples/test_all/fibonacci/
H A Dfibonacci.cpp255 oneapi::tbb::task_group tg; in ConcurrentHashSerialFib() local
257 tg.run(ConcurrentHashSerialFibTask(Fib, n)); in ConcurrentHashSerialFib()
258 tg.run(ConcurrentHashSerialFibTask(Fib, n)); in ConcurrentHashSerialFib()
259 tg.wait(); in ConcurrentHashSerialFib()
/oneTBB/include/oneapi/tbb/
H A Dtask_group.h647 status = tg.wait(); in operator()
651 task_group& tg;
655 : tg(a_group), status(tgs) {} in wait_delegate()
662 status = tg.run_and_wait(func); in operator()
/oneTBB/doc/main/tbb_userguide/design_patterns/
H A DNon-Preemptive_Priorities.rst129 oneapi::tbb::task_group tg;
133 tg.run(RunWorkItem());