| /oneTBB/test/conformance/ |
| H A D | conformance_task_group.cpp | 39 bool run {false}; variable
42 run = true; in __anon0c2008c70102()
56 bool run {false}; variable
59 run = true; in __anon0c2008c70202()
62 tg.run(std::move(h));
77 bool run {false}; variable
80 run = true; in __anon0c2008c70302()
167 tg.run(std::move(h)); in __anon0c2008c70902()
187 tg.run(std::move(h));
202 m_tg.run( *this ); in operator ()()
[all …]
|
| H A D | conformance_task_arena.cpp | 137 bool run{false}; variable
139 auto task_handle = tg.defer([&]{ run = true; }); in __anon3e0b77410602()
144 CHECK(run == true);
155 bool run{false}; variable
158 auto task_handle = tg.defer([&]{ run = true; }); in __anon3e0b77410702()
165 CHECK(run == true);
179 bool run{false}; variable
186 run = true; in __anon3e0b77410a02()
194 CHECK(run == true);
|
| H A D | conformance_resumable_tasks.cpp | 60 tg.run([&tg, &suspend, &resume] { in __anon366fea4d0302()
63 tg.run([sp, &resume] { in __anon366fea4d0302()
|
| /oneTBB/test/tbb/ |
| H A D | test_task_group.cpp | 492 tg.run(std::move(h)); in TestManualCancellationWithFunctor()
640 g.run( tf ); g.wait(); in TestConstantFunctorRequirement()
678 tg.run( mpf ); in TestBareFunctors()
683 tg.run( std::move(mpf) ); in TestBareFunctors()
1029 m_tg.run( *this ); in operator ()()
1040 tg.run( uf );
1061 inner_tg.run([&] { in run_cancellation_use_case()
1090 outer_tg.run(outer_tg_task); in run_cancellation_use_case()
1138 tg.run([&]{ in __anoneb262a491c02()
1140 run = true; in __anoneb262a491c02()
[all …]
|
| H A D | test_parallel_sort.cpp | 154 static void run() { in run() function
166 static void run(Comparator& comp) { in run() function
182 parallel_sort_test<ContainerType, /*Size*/0 >::run(comp); in parallel_sort_test_suite()
183 parallel_sort_test<ContainerType, /*Size*/1 >::run(comp); in parallel_sort_test_suite()
184 parallel_sort_test<ContainerType, /*Size*/10 >::run(comp); in parallel_sort_test_suite()
185 parallel_sort_test<ContainerType, /*Size*/9999 >::run(comp); in parallel_sort_test_suite()
194 parallel_sort_test<ContainerType, /*Size*/0 >::run(); in parallel_sort_test_suite()
195 parallel_sort_test<ContainerType, /*Size*/1 >::run(); in parallel_sort_test_suite()
196 parallel_sort_test<ContainerType, /*Size*/10 >::run(); in parallel_sort_test_suite()
197 parallel_sort_test<ContainerType, /*Size*/9999 >::run(); in parallel_sort_test_suite()
[all …]
|
| H A D | test_parallel_reduce.cpp | 238 static void run() { in run() function
240 ParallelReduceTestRunner<Mode + 1>::run(); in run()
246 static void run() { in run() function
253 static void run() { in run() function
255 ParallelDeterministicReduceTestRunner<Mode + 1>::run(); in run()
261 static void run() { in run() function
626 test_cancellation::ParallelReduceTestRunner</*First mode = */0>::run();
632 test_cancellation::ParallelDeterministicReduceTestRunner</*First mode = */0>::run();
|
| H A D | test_async_node.cpp | 414 static int run(int async_expected_items = UNKNOWN_NUMBER_OF_ITEMS) { in run() function
533 static int run(int nthreads, int async_expected_items = UNKNOWN_NUMBER_OF_ITEMS) { in run() function
593 spin_test<int, int>::run(nthreads); in test_for_spin_avoidance()
599 basic_test<Input, Output>::run(); in run_tests()
600 basic_test<Input, Output>::run(NUMBER_OF_MSGS); in run_tests()
601 basic_test<place_wrapper<Input>, place_wrapper<Output> >::run(); in run_tests()
602 basic_test<place_wrapper<Input>, place_wrapper<Output> >::run(NUMBER_OF_MSGS); in run_tests()
652 static int run () in run() function in enqueueing_on_inner_level
665 enqueueing_on_inner_level<int, int>::run(); in run_test_enqueueing_on_inner_level()
|
| H A D | test_eh_algorithms.cpp | 1184 tg.run( cancellator ); in TestCancelation1_parallel_for_each()
1186 tg.run( worker ); in TestCancelation1_parallel_for_each()
1351 void run () { in run() function in CustomPipeline
1359 void run ( tbb::task_group_context& ctx ) { in run() function in CustomPipeline
1377 testPipeline.run(); in Test1_pipeline()
1407 testPipeline.run(); in operator ()()
1422 testPipeline.run(); in Test2_pipeline()
1441 testPipeline.run(ctx); in operator ()()
1461 testPipeline.run(); in Test3_pipeline()
1515 testPipeline.run(ctx); in operator ()()
[all …]
|
| /oneTBB/test/tbbmalloc/ |
| H A D | test_malloc_used_by_lib.cpp | 64 utils::FunctionAddress run; member in UseDll
66 UseDll(utils::FunctionAddress runPtr) : run(runPtr) { } in UseDll()
68 (*run)(); in operator ()()
129 for (int run = 0; run < 2; run++) { variable
133 if (run) {
|
| /oneTBB/include/oneapi/tbb/ |
| H A D | parallel_reduce.h | 150 run(range, body, partitioner, context); in run()
296 run(range, body, partitioner, context); in run()
529 ::run(range, body, partitioner ); in __TBB_requires()
542 ::run( range, body, partitioner ); in __TBB_requires()
555 ::run( range, body, partitioner ); in __TBB_requires()
594 ::run( range, body, partitioner, context ); in __TBB_requires()
607 ::run( range, body, partitioner, context ); in __TBB_requires()
706 ::run(range, body, partitioner); in __TBB_requires()
718 ::run(range, body, partitioner); in __TBB_requires()
741 ::run(range, body, partitioner, context); in __TBB_requires()
[all …]
|
| H A D | parallel_for.h | 99 static void run(const Range& range, const Body& body, Partitioner& partitioner) { in run() function
101 run(range, body, partitioner, context); in run()
229 …start_for<Range,Body,const __TBB_DEFAULT_PARTITIONER>::run(range,body,__TBB_DEFAULT_PARTITIONER()); in __TBB_requires()
237 start_for<Range,Body,const simple_partitioner>::run(range,body,partitioner); in __TBB_requires()
245 start_for<Range,Body,const auto_partitioner>::run(range,body,partitioner); in __TBB_requires()
253 start_for<Range,Body,const static_partitioner>::run(range,body,partitioner); in __TBB_requires()
261 start_for<Range,Body,affinity_partitioner>::run(range,body,partitioner); in __TBB_requires()
277 start_for<Range,Body,const simple_partitioner>::run(range, body, partitioner, context); in __TBB_requires()
285 start_for<Range,Body,const auto_partitioner>::run(range, body, partitioner, context); in __TBB_requires()
293 start_for<Range,Body,const static_partitioner>::run(range, body, partitioner, context); in __TBB_requires()
[all …]
|
| /oneTBB/test/common/ |
| H A D | concurrency_tracker.h | 104 bool run() { in run() function
147 ok = o.run();
149 ok = o.run();
156 return o.run(); in isEqual()
163 o.run(); // ignore result, as without a barrier it is not reliable in checkLessOrEqual()
|
| H A D | exception_handling.h | 246 tg.run([]{}); in WaitUntilConcurrencyPeaks()
311 tg.run(launcher);
312 tg.run(cancellator);
|
| /oneTBB/doc/main/tbb_userguide/Migration_Guide/ |
| H A D | Task_API.rst | 52 tg.run(ChildTask1{/*params*/});
53 tg.run(ChildTask2{/*params*/});
181 tg.run([&i = items[i], &tg] {
187 tg.run(OtherWork{});
197 You can re-run the functor by passing ``*this`` to the ``oneapi::tbb::task_group::run()``
213 m_task_group.run(*this);
223 tg.run(SharedStateFunctor{data, tg});
245 m_task_group.run(*this);
300 m_tg.run(*this);
378 tg.run([&tg](){
[all …]
|
| /oneTBB/.github/workflows/ |
| H A D | ci.yml | 42 run: |
52 run: |
67 run: |
74 run: |
100 run: |
120 run: |
138 run: |
174 run: |
200 run: |
235 run: |
[all …]
|
| /oneTBB/python/tbb/ |
| H A D | api.i | 96 tg.run([&b]{
137 void run( PyObject *c ) { $self->run(PyCaller(c)); } in run() function
138 void run( PyObject *c, task_arena *a ) { $self->run(ArenaPyCaller(a, c)); } in run() function
|
| /oneTBB/doc/main/tbb_userguide/design_patterns/ |
| H A D | Local_Serializer.rst | 85 Template function ``EnqueueWork`` causes functor ``f`` to run when
101 * - No higher priority work is ready to run.
140 virtual void run() = 0;
149 /*override*/ void run() {
173 Virtual method ``run()`` is invoked when it becomes time to run the
187 Step 3 is the difference from the operation of ConcreteWorkItem::run.
256 invoke\ ``item->run()``. This approach has relatively low overhead
264 to enqueue a task that invokes ``item->run()``. Doing so
279 item. The term "run" means to run work immediately, or if there are
|
| H A D | Non-Preemptive_Priorities.rst | 99 virtual void run() = 0;
107 /*override*/ void run() {
119 collection of work and fires off tasks through the ``oneapi::tbb::task_group::run`` interface
133 tg.run(RunWorkItem());
142 item->run();
|
| /oneTBB/doc/main/reference/ |
| H A D | task_group_extensions.rst | 50 void run(F&& f);
66 … be created using ``*this`` ``task_group``. That is, the one for which the run method is called, o…
73 … be created using ``*this`` ``task_group``. That is, the one for which the run method is called, o…
76 .. cpp:function:: template<typename F> void run(F&& f)
81 …be created with ``*this`` ``task_group``. It means, with the one for which run method is called, o…
|
| /oneTBB/examples/task_arena/fractal/ |
| H A D | fractal.cpp | 151 void fractal::run(oneapi::tbb::task_group_context &context) { in run() function in fractal
167 f.run(context[num]); in calc_fractal()
193 void fractal_group::run(bool create_second_fractal) { in run() function in fractal_group
203 groups[1].run([&] { in run()
210 groups[0].run([&] { in run()
|
| H A D | fractal.hpp | 64 void run(oneapi::tbb::task_group_context &context);
132 void run(bool create_second_fractal = true);
|
| /oneTBB/python/rml/ |
| H A D | ipc_server.cpp | 287 void run();
333 void run();
346 void run();
507 self->run(); in thread_routine()
557 void ipc_worker::run() { in run() function in tbb::detail::rml::ipc_worker
649 self->run(); in thread_routine()
656 void ipc_waker::run() { in run() function in tbb::detail::rml::ipc_waker
748 self->run(); in thread_routine()
755 void ipc_stopper::run() { in run() function in tbb::detail::rml::ipc_stopper
|
| /oneTBB/examples/migration/recursive_fibonacci/ |
| H A D | task_emulation_layer.h | 185 m_tg.run(std::move(m_callback)); in execute()
211 tg_pool[tbb::this_task_arena::current_thread_index()].run(std::forward<F>(f)); in run_task()
216 tg_pool[tbb::this_task_arena::current_thread_index()].run(std::ref(*f)); in run_task()
|
| /oneTBB/ |
| H A D | Bazel.md | 79 Switch to the folder with the files created earlier and run the binary with `bazel run //:Demo`.
|
| H A D | INSTALL.md | 21 | `-G <generator>` | Specify project generator | For more information, run cmake `–help`. …
27 To build the system, run:
66 If you want to install specific components after configuration and build, run:
|