Home
last modified time | relevance | path

Searched refs:forward (Results 1 – 25 of 50) sorted by relevance

12

/oneTBB/examples/migration/recursive_fibonacci/
H A Dtask_emulation_layer.h87 C* continuation = new C{std::forward<Args>(args)...}; in allocate_continuation()
96 return create_child_impl<F>(std::forward<Args>(args)...); in create_child()
102 return create_child_impl<F>(std::forward<Args>(args)...); in create_child_and_increment()
107 return allocate_child_impl<F>(std::forward<Args>(args)...); in allocate_child()
113 return allocate_child_impl<F>(std::forward<Args>(args)...); in allocate_child_and_increment()
152 F obj{std::forward<Args>(args)...}; in create_child_impl()
160 F* obj = new F{std::forward<Args>(args)...}; in allocate_child_impl()
195 F obj{std::forward<Args>(args)...}; in create_root_task()
203 F* obj = new F{std::forward<Args>(args)...}; in allocate_root_task()
211 tg_pool[tbb::this_task_arena::current_thread_index()].run(std::forward<F>(f)); in run_task()
/oneTBB/test/tbb/
H A Dtest_collaborative_call_once.cpp62 (*this)(std::forward<Args>(args)...); in operator ()()
79 tbb::collaborative_call_once(flag, std::forward<Fn>(body), std::forward<Args>(args)...); in call_once_in_for_loop()
87 auto stored_pack = tbb::detail::d0::save_pack(std::forward<Args>(args)...); in call_once_in_parallel_for()
88 auto func = [&] { tbb::detail::d0::call(std::forward<Fn>(body), std::move(stored_pack)); }; in call_once_in_parallel_for()
96 tbb::collaborative_call_once(flag, std::forward<Fn>(body), std::forward<Args>(args)...); in call_once_in_parallel_for()
108 auto stored_pack = tbb::detail::d0::save_pack(std::forward<Args>(args)...); in call_once_threads()
109 auto func = [&] { tbb::detail::d0::call(std::forward<Fn>(body), std::move(stored_pack)); }; in call_once_threads()
118 tbb::collaborative_call_once(flag, std::forward<Fn>(body), std::forward<Args>(args)...); in call_once_threads()
H A Dtest_parallel_for.cpp227 tbb::parallel_for(std::forward<Args>(args)..., part, my_ctx); in run_parallel_for()
235 tbb::parallel_for(std::forward<Args>(args)..., my_ctx); in run_overload()
239 run_parallel_for<tbb::simple_partitioner>(std::forward<Args>(args)...); in run_overload()
243 run_parallel_for<tbb::auto_partitioner>(std::forward<Args>(args)...); in run_overload()
247 run_parallel_for<tbb::static_partitioner>(std::forward<Args>(args)...); in run_overload()
251 run_parallel_for<tbb::affinity_partitioner>(std::forward<Args>(args)...); in run_overload()
309 tbb::parallel_for(std::forward<Args>(args)...);
H A Dtest_parallel_reduce.cpp134 tbb::parallel_reduce(std::forward<Args>(args)..., my_ctx); in run_parallel_reduce()
138 … tbb::parallel_reduce(std::forward<Args>(args)..., tbb::simple_partitioner{}, my_ctx); in run_parallel_reduce()
142 tbb::parallel_reduce(std::forward<Args>(args)..., tbb::auto_partitioner{}, my_ctx); in run_parallel_reduce()
146 … tbb::parallel_reduce(std::forward<Args>(args)..., tbb::static_partitioner{}, my_ctx); in run_parallel_reduce()
151 tbb::parallel_reduce(std::forward<Args>(args)..., aff, my_ctx); in run_parallel_reduce()
185 tbb::parallel_deterministic_reduce(std::forward<Args>(args)..., my_ctx); in run_parallel_deterministic_reduce()
189 …tbb::parallel_deterministic_reduce(std::forward<Args>(args)..., tbb::simple_partitioner{}, my_ctx); in run_parallel_deterministic_reduce()
193 …tbb::parallel_deterministic_reduce(std::forward<Args>(args)..., tbb::static_partitioner{}, my_ctx); in run_parallel_deterministic_reduce()
271 tbb::parallel_reduce(std::forward<Args>(args)...);
276 tbb::parallel_deterministic_reduce(std::forward<Args>(args)...);
/oneTBB/include/oneapi/tbb/detail/
H A D_template_helpers.h295 return std::forward<F>(f)(std::forward<Preceding>(params)...);
299 return std::forward<F>(f)(std::forward<Preceding>(params)...);
316 : pack_remainder(std::forward<Types>(types)...), leftmost_value(std::forward<T>(t)) {}
326 std::forward<F>(f), static_cast<pack_remainder&>(pack),
327 std::forward<Preceding>(params)... , pack.leftmost_value
334 std::forward<F>(f), static_cast<pack_remainder&&>(pack),
335 std::forward<Preceding>(params)... , std::move(pack.leftmost_value)
343 std::decay<Pack>::type::template call<void>(std::forward<F>(f), std::forward<Pack>(p));
348 return std::decay<Pack>::type::template call<Ret>(std::forward<F>(f), std::forward<Pack>(p));
353 return stored_pack<Types...>(std::forward<Types>(types)...);
H A D_utils.h305 { !std::forward<T>(t) } -> boolean_testable_impl; in atomic_do_once()
356 return std::invoke(std::forward<F>(f), std::forward<Args>(args)...); in atomic_do_once()
359 noexcept(noexcept(std::forward<F>(f)(std::forward<Args>(args)...))) in atomic_do_once()
360 -> decltype(std::forward<F>(f)(std::forward<Args>(args)...)) in atomic_do_once()
362 return std::forward<F>(f)(std::forward<Args>(args)...); in atomic_do_once()
H A D_small_object_pool.h55 auto constructed_object = new(allocated_object) Type(std::forward<Args>(args)...); in new_object()
63 auto constructed_object = new(allocated_object) Type(std::forward<Args>(args)...); in new_object()
/oneTBB/include/oneapi/tbb/
H A Dcollaborative_call_once.h106 function_stack_task<F> t{ std::forward<F>(f), m_storage.m_wait_context }; in alignas()
165 std::forward<Fn>(f)(); in do_collaborative_call_once()
215 auto stored_pack = save_pack(std::forward<Args>(args)...); in collaborative_call_once()
216 auto func = [&] { call(std::forward<Fn>(fn), std::move(stored_pack)); }; in collaborative_call_once()
218 auto func = [&] { fn(std::forward<Args>(args)...); }; in collaborative_call_once()
H A Dtask_group.h102 m_func(std::forward<FF>(f)) {}
109 task_handle th = std::forward<F>(f)(); in task_ptr_or_nullptr_impl()
115 std::forward<F>(f)(); in task_ptr_or_nullptr_impl()
122 decltype(std::forward<F>(f)()) in task_ptr_or_nullptr()
125 return task_ptr_or_nullptr_impl(is_void_t{}, std::forward<F>(f)); in task_ptr_or_nullptr()
132 std::forward<F>(f)(); in task_ptr_or_nullptr()
534 …return alloc.new_object<function_task<typename std::decay<F>::type>>(std::forward<F>(f), m_wait_ct… in prepare_task()
546 …d2::task_handle_task* function_task_p = alloc.new_object<function_task_t>(std::forward<F>(f), m_w… in prepare_task_handle()
603 spawn(*prepare_task(std::forward<F>(f)), context()); in run()
617 return prepare_task_handle(std::forward<F>(f)); in defer()
[all …]
H A Dparallel_invoke.h207 parallel_invoke_impl(std::forward<T>(t), std::forward<Fs>(args)...);
216 invoke_helper<std::tuple<>, Fs...>()(std::forward<Fs>(fs)...);
H A Dconcurrent_queue.h197 internal_push(std::forward<Args>(args)...); in emplace()
246 …esentation->choose(k).push(k, *my_queue_representation, my_allocator, std::forward<Args>(args)...); in internal_push()
487 internal_push(std::forward<Args>(args)...); in emplace()
492 return internal_push_if_not_full(std::forward<Args>(args)...); in try_emplace()
579 …->choose(ticket).push(ticket, *my_queue_representation, my_allocator, std::forward<Args>(args)...); in internal_push()
595 …->choose(ticket).push(ticket, *my_queue_representation, my_allocator, std::forward<Args>(args)...); in internal_push_if_not_full()
H A Dconcurrent_map.h149 return this->emplace(std::forward<P>(value)); in insert()
156 return this->emplace_hint(hint, std::forward<P>(value)); in insert()
266 return this->emplace(std::forward<P>(value)); in insert()
273 return this->emplace_hint(hint, std::forward<P>(value)); in insert()
H A Dtask_arena.h233 …r1::enqueue(*alloc.new_object<enqueue_task<typename std::decay<F>::type>>(std::forward<F>(f), allo… in enqueue_impl()
388 enqueue_impl(std::forward<F>(f), this); in enqueue()
472 enqueue_impl(std::forward<F>(f), nullptr); in enqueue()
H A Dparallel_for_each.h84 -> decltype(tbb::detail::invoke(body, std::forward<ItemArg>(item)), void()) {
91 tbb::detail::invoke(body, std::forward<ItemArg>(item));
100 -> decltype(tbb::detail::invoke(body, std::forward<ItemArg>(item), *feeder), void()) {
108 tbb::detail::invoke(body, std::forward<ItemArg>(item), *feeder);
122 item(std::forward<ItemType>(input_item)), in feeder_item_task()
H A Dtbb_allocator.h90 { ::new (p) U(std::forward<Args>(args)...); } in construct()
H A Dconcurrent_unordered_map.h131 return this->emplace(std::forward<P>(value)); in insert()
137 return this->emplace_hint(hint, std::forward<P>(value)); in insert()
292 return this->emplace(std::forward<P>(value)); in insert()
298 return this->emplace_hint(hint, std::forward<P&&>(value)); in insert()
H A Denumerable_thread_specific.h659 construct_by_args( P&& ... args ) : pack(std::forward<P>(args)...) {}
678 …template<typename... P> callback_leaf( P&& ... params ) : Constructor(std::forward<P>(params)...) …
700 return new(where) callback_leaf( std::forward<P>(params)... );
875 …callback_leaf<construct_by_args<T,P1,P...> >::make( std::forward<P1>(arg1), std::forward<P>(args).…
/oneTBB/doc/main/tbb_userguide/
H A DFlow_Graph_Reservation.rst119 ``bn`` attempts to forward 2 to ``jn``. ``jn`` does not accept the value
148 ``buf1`` attempts to forward 3 to ``jn``. ``jn`` does not accept the
170 ``buf2`` attempts to forward 4 to ``jn``. ``jn`` does not accept the
172 ``jn`` have predecessors, a task to build and forward a message from
210 switches back to the forward direction.
213 remains in ``buf1`` (in case the attempt to forward a message from
239 switches back to the forward direction.
H A DFlow_Graph_Message_Passing_Protocol.rst14 repeatedly attempt to forward its message until the successor accepts
/oneTBB/test/conformance/
H A Dconformance_parallel_scan.cpp65 oneapi::tbb::parallel_scan(std::forward<Args>(args)..., Partitioner()); in operator ()()
73 oneapi::tbb::parallel_scan(std::forward<Args>(args)...); in operator ()()
144 auto result = oneapi::tbb::parallel_scan(std::forward<Args>(args)...); in test_pscan_invoke()
H A Dconformance_task_group.cpp222 std::forward<CancelF>(cancel)(outer_tg); in run_cancellation_use_case()
230 outer_status = std::forward<WaitF>(wait)(outer_tg); in run_cancellation_use_case()
/oneTBB/doc/main/reference/
H A Dparallel_for_each_semantics.rst51 `Forward iterator` named requirements from [forward.iterators] ISO C++ Standard section, ``tbb::par…
59 If the ``iterator`` satisfies `Forward iterator` named requirements from [forward.iterators] ISO C+…
/oneTBB/examples/graph/dining_philosophers/
H A Ddining_philosophers.cpp141 void forward(const oneapi::tbb::flow::continue_msg &in,
184 my_philosopher.forward(in, out); in operator ()()
195 void philosopher::forward(const oneapi::tbb::flow::continue_msg & /*in*/, in forward() function in philosopher
/oneTBB/test/common/
H A Dtest_follows_and_precedes_api.h242 NodeType node(follows(preds[0], preds[1], preds[2]), std::forward<ConstructorArgs>(args)...);
259 …NodeType node(precedes(successors[0], successors[1], successors[2]), std::forward<ConstructorArgs>…
/oneTBB/src/tbb/
H A Dconcurrent_monitor.h261 while (!guarded_call(std::forward<Pred>(pred), node)) { in wait()
466 res = std::forward<Pred>(predicate)(); in guarded_call()

12