Home
last modified time | relevance | path

Searched refs:execute (Results 1 – 25 of 93) sorted by relevance

1234

/oneTBB/doc/main/tbb_userguide/
H A DMapping_Nodes2Tasks.rst12 has unlimited concurrency, these tasks can execute concurrently if there
35 it sequentially spawns tasks to execute its body, λ\ :sub:`m`, on the
44 Likewise, the body tasks execute the lambda expressions and then put
47 used to execute tasks from the oneTBB work pool while it is waiting.
51 execute all of the tasks that can be executed in parallel. If there are
53 available to execute them.
H A DDependence_Graph.rst10 execute the body objects when it is legal to do so according to the
33 task to execute their body when this count is equal to the total number
129 task to execute the body of A. Likewise, the body tasks execute the
132 this case the calling thread may be used to execute tasks from the
137 execute all of the tasks that can be executed concurrently in parallel.
139 to wait until a thread is available to execute them.
H A Dcancel_a_graph.rst45 execute will execute to completion, but any node that has not started to
46 execute will not start. So in the example above, f2 will print both the
H A DGuiding_Task_Scheduler_Execution.rst51 arenas[j].execute([&task_groups, &j](){ 
57 arenas[j].execute([&task_groups, &j](){ task_groups[j].wait(); });
77 arena.execute( [] {
93 no_ht_arena.execute( [] {
106 arena.execute( [] {
H A Dwork_isolation.rst11 group of tasks to complete might execute other available tasks. In
67 One of these ways is to execute the inner level loop in a separate
79 nested.execute( []{
97 inside an isolated region, a thread can only execute tasks spawned
H A Destimate_flow_graph_performance.rst43 ``multifunction_nodes`` execute within spawned tasks by default. This
45 scheduling when estimating the time it takes for a node to execute
/oneTBB/test/tbb/
H A Dtest_task_arena.cpp208 a2.execute(work); in TestConcurrentArenasFunc()
210 a3.execute([] { in TestConcurrentArenasFunc()
446 my_a.execute( *this ); in operator ()()
529 a.execute([&a] { in TestMandatoryConcurrency()
1321 arena().execute(f2); in Test()
1818 arena.execute([&ets] { in __anon1d1198c31c02()
1932 arena.execute([] { in __anon1d1198c31e02()
1953 arena.execute([&] { in __anon1d1198c32002()
1971 arena.execute([&] { in __anon1d1198c32202()
2029 arena.execute([&]{ in __anon1d1198c32502()
[all …]
H A Dtest_eh_algorithms.cpp392 a.execute([] { in __anone85726900102()
413 a.execute([] { in __anone85726900202()
434 a.execute([] { in __anone85726900302()
455 a.execute([] { in __anone85726900402()
476 a.execute([] { in __anone85726900502()
688 a.execute([] { in __anone85726900602()
709 a.execute([] { in __anone85726900702()
730 a.execute([] { in __anone85726900802()
751 a.execute([] { in __anone85726900902()
1044 a.execute([] { in __anone85726900a02()
[all …]
H A Dtest_flow_graph.cpp287 arena.execute( in test_graph_arena()
292 midway_arena.execute(nodes_test_functor(&midway_arena, g)); in test_graph_arena()
303 arena.execute(
316 arena.execute(
329 arena.execute(
H A Dtest_resumable_tasks.cpp157 nested_arena.execute(innermost_arena_body); in operator ()()
185 outermost_arena.execute(outer_arena_body); in TestNestedArena()
350 arena.execute([&tg, &asyncActivity, &iter]() { in TestNativeThread()
360 arena.execute([&tg](){ in TestNativeThread()
393 arena.execute([] { in TestObservers()
H A Dtest_task.cpp54 task* execute( tbb::detail::d1::execution_data& ) override { in execute() function in CountingTask
354 task* execute(tbb::detail::d1::execution_data&) override { in execute() function
425 task* execute(tbb::detail::d1::execution_data&) override { in execute() function
559 test_arena.execute([&wait, &test_tasks, &test_arena, &test_context, &resumed, task_number] { in __anon509d20bd1302()
574 test_arena.execute([&wait, &test_context] { in __anon509d20bd1602()
605 …test_arena.execute([&test_tasks, &task_body, &wait, &test_context, &test_arena, iter_counter, task… in __anon509d20bd1902()
710 test_arena.execute([&test_tasks, &wait, &test_context, task_number] { in __anon509d20bd1f02()
734 tbb::detail::d1::task* execute(tbb::detail::d1::execution_data& ) override { in execute() function
777 test_arena.execute([]{}); in __anon509d20bd2102()
788 test_arena.execute([&] { in __anon509d20bd2302()
H A Dtest_arena_constraints.cpp56 current_level_arena.execute( in recursive_arena_binding()
112 arena.execute([]{ in __anon2861f8e80202()
/oneTBB/test/conformance/
H A Dconformance_task_arena.cpp47 a.execute([&] { in __anon3e0b77410202()
112 a.execute([&] { in __anon3e0b77410502()
157 arena.execute([&]{ in __anon3e0b77410702()
184 arena.execute([&]{ in __anon3e0b77410a02()
/oneTBB/include/oneapi/tbb/detail/
H A D_aggregator.h65 void execute( OperationType* op, HandlerType& handle_operations, bool long_life_time = true ) {
149 void execute(OperationType* op) { in execute() function
150 aggregator_generic<OperationType>::execute(op, handle_operations); in execute()
H A D_flow_graph_body_impl.h257 task* execute(execution_data& ed) override {
286 task* execute(execution_data& ed) override {
310 task* execute(execution_data& ed) override {
364 graph_task* execute() override {
H A D_flow_graph_node_impl.h100 my_aggregator.execute(&op_data); in register_predecessor()
108 my_aggregator.execute(&op_data); in remove_predecessor()
144 my_aggregator.execute(&op_data); in try_get_postponed_task()
263 my_aggregator.execute(&op_data); in internal_try_put_bypass()
275 my_aggregator.execute(&check_op); in try_put_task_impl()
316 my_aggregator.execute(&op_data); in forward_task()
668 graph_task* execute() override {
H A D_flow_graph_join_impl.h318 my_aggregator.execute(&op_data);
325 my_aggregator.execute(&op_data);
332 my_aggregator.execute(&op_data);
339 my_aggregator.execute(&op_data);
345 my_aggregator.execute(&op_data);
452 my_aggregator.execute(&op_data);
480 my_aggregator.execute(&op_data);
488 my_aggregator.execute(&op_data);
599 my_aggregator.execute(&op_data);
639 my_aggregator.execute(&op_data);
[all …]
/oneTBB/doc/main/tbb_userguide/snippets/
H A Dflow_graph_examples.cpp34 arena.execute( [&]() { in flow_graph_attach_to_arena_1()
59 arena.execute( [&]() { in flow_graph_attach_to_arena_2()
/oneTBB/examples/migration/recursive_fibonacci/
H A Dfibonacci_two_tasks.h36 task_emulation::base_task* execute() override { in execute() function
48 task_emulation::base_task* execute() override { in execute() function
H A Dtask_emulation_layer.h58 base_task* bypass = const_cast<base_task*>(this)->execute(); in operator()
83 virtual base_task* execute() = 0;
184 base_task* execute() override { in execute() function
/oneTBB/examples/task_arena/fractal/
H A Dfractal.cpp202 arenas[1].execute([&] { in run()
209 arenas[0].execute([&] { in run()
216 arenas[1].execute([&] { in run()
221 arenas[0].execute([&] { in run()
/oneTBB/python/tbb/
H A Dapi.i72 my_arena->execute(PyCaller(my_callable, false)); in operator()
126 void execute( PyObject *c ) { $self->execute(PyCaller(c)); } in execute() function
/oneTBB/include/oneapi/tbb/
H A Dtask_arena.h90 TBB_EXPORT void __TBB_EXPORTED_FUNC execute(d1::task_arena_base&, d1::delegate_base&);
216 task* execute(execution_data& ed) override { in execute() function
251 r1::execute(*this, func); in execute_impl()
403 auto execute(F&& f) -> decltype(f()) {
H A Dparallel_for_each.h149 task* execute(execution_data& ed) override { in execute() function
221 task* execute(execution_data&) override { in execute() function
282 task* execute(execution_data& ed) override {
347 task* execute(execution_data& ed) override {
508 task* execute(execution_data& ed) override {
546 task* execute(execution_data& ed) override {
582 task* execute(execution_data&) override {
/oneTBB/doc/main/tbb_userguide/Migration_Guide/
H A DTask_Scheduler_Init.rst64 arena.execute([]{
87 arena.execute([]{
104 arena.execute([]{

1234