Home
last modified time | relevance | path

Searched refs:task_group_context (Results 1 – 25 of 62) sorted by relevance

123

/oneTBB/src/tbb/
H A Dtask_group_context.cpp54 void task_group_context_impl::destroy(d1::task_group_context& ctx) { in destroy()
167 if (state <= d1::task_group_context::state::locked) { in bind_to()
168 if (state == d1::task_group_context::state::created && in bind_to()
172 …(typename std::underlying_type<d1::task_group_context::state>::type)d1::task_group_context::state:… in bind_to()
181 d1::task_group_context::state release_state{}; in bind_to()
200 …ask_group_state(d1::task_group_context& ctx, std::atomic<std::uint32_t> d1::task_group_context::* … in propagate_task_group_state()
244 void task_group_context_impl::reset(d1::task_group_context& ctx) { in reset()
272 …oid task_group_context_impl::copy_fp_settings(d1::task_group_context& ctx, const d1::task_group_co… in copy_fp_settings()
336 void __TBB_EXPORTED_FUNC initialize(d1::task_group_context& ctx) { in initialize()
339 void __TBB_EXPORTED_FUNC destroy(d1::task_group_context& ctx) { in destroy()
[all …]
H A Dscheduler_common.h107 static d1::task_group_context*& context(d1::task& t) { in context()
108 task_group_context** tgc = reinterpret_cast<task_group_context**>(&t.m_reserved[0]); in context()
149 const d1::task_group_context* curr_ctx;
165 void set_ctx(const d1::task_group_context* ctx) { in set_ctx()
575 static void destroy(d1::task_group_context&);
576 static void initialize(d1::task_group_context&);
579 static void bind_to(d1::task_group_context&, thread_data*);
580 …ropagate_task_group_state(d1::task_group_context&, std::atomic<uint32_t> d1::task_group_context::*…
583 static void reset(d1::task_group_context&);
584 static void capture_fp_settings(d1::task_group_context&);
[all …]
H A Dthread_data.h41 class task_group_context; variable
140 …gate_task_group_state(std::atomic<uint32_t> d1::task_group_context::* mptr_state, d1::task_group_c…
202 d1::task_group_context my_default_context;
239 …task_group_state(std::atomic<std::uint32_t> d1::task_group_context::* mptr_state, d1::task_group_c… in propagate_task_group_state()
245 d1::task_group_context& ctx = __TBB_get_object_ref(d1::task_group_context, my_node, &(*it)); in propagate_task_group_state()
H A Dtask_dispatcher.cpp30 void __TBB_EXPORTED_FUNC spawn(d1::task& t, d1::task_group_context& ctx) { in spawn()
42 void __TBB_EXPORTED_FUNC spawn(d1::task& t, d1::task_group_context& ctx, d1::slot_id id) { in spawn()
77 void __TBB_EXPORTED_FUNC submit(d1::task& t, d1::task_group_context& ctx, arena* a, std::uintptr_t … in submit()
119 …UNC execute_and_wait(d1::task& t, d1::task_group_context& t_ctx, d1::wait_context& wait_ctx, d1::t… in execute_and_wait()
124 void __TBB_EXPORTED_FUNC wait(d1::wait_context& wait_ctx, d1::task_group_context& w_ctx) { in wait()
140 d1::task_group_context* __TBB_EXPORTED_FUNC current_context() { in current_context()
153 …patcher::execute_and_wait(d1::task* t, d1::wait_context& wait_ctx, d1::task_group_context& w_ctx) { in execute_and_wait()
H A Dcancellation_disseminator.h38 …agate_task_group_state(std::atomic<uint32_t> d1::task_group_context::*mptr_state, d1::task_group_c… in propagate_task_group_state()
39 …if (src.my_may_have_children.load(std::memory_order_relaxed) != d1::task_group_context::may_have_c… in propagate_task_group_state()
H A Dthreading_control.h64 void propagate_task_group_state(std::atomic<uint32_t> d1::task_group_context::*mptr_state,
65 d1::task_group_context& src, uint32_t new_state);
112 void propagate_task_group_state(std::atomic<uint32_t> d1::task_group_context::*mptr_state,
113 d1::task_group_context& src, uint32_t new_state);
/oneTBB/test/conformance/
H A Dconformance_task_group_context.cpp29 oneapi::tbb::task_group_context ctx;
33 oneapi::tbb::task_group_context ctx{ oneapi::tbb::task_group_context::bound };
37 oneapi::tbb::task_group_context ctx{ oneapi::tbb::task_group_context::isolated
38 …, oneapi::tbb::task_group_context::default_traits | oneapi::tbb::task_group_context::fp_settings |…
46 …oneapi::tbb::task_group_context ctx{ oneapi::tbb::task_group_context::bound, oneapi::tbb::task_gro…
H A Dconformance_parallel_invoke.cpp54 static void run_validate_and_reset(oneapi::tbb::task_group_context* context_ptr) { in run_validate_and_reset()
69 void correctness_test(oneapi::tbb::task_group_context* context_ptr = nullptr) { in correctness_test()
98 oneapi::tbb::task_group_context context;
176 oneapi::tbb::task_group_context &my_ctx;
188 ParInvokeLauncher ( oneapi::tbb::task_group_context& ctx ) : my_ctx(ctx) {} in ParInvokeLauncher()
/oneTBB/include/oneapi/tbb/
H A Dtask_group.h47 class task_group_context; variable
164 class task_group_context : no_copy {
222 task_group_context* my_parent;
271 task_group_context(task_group_context* actual_context) in task_group_context() function
348 ~task_group_context() { in ~task_group_context()
496 task_group_context m_context;
537 task_group_context& context() noexcept { in context()
554 , m_context(task_group_context::bound, task_group_context::default_traits | traits)
557 task_group_base(task_group_context& ctx) in task_group_base()
634 task_group_context& context;
[all …]
H A Dparallel_invoke.h76 task_group_context& my_execution_context;
79 …task(const F1& f1, const F2& f2, const F3& f3, wait_context& wait_ctx, task_group_context& context, in invoke_subroot_task()
137 void invoke_recursive_separation(wait_context& root_wait_ctx, task_group_context& context, const F1… in invoke_recursive_separation()
146 void invoke_recursive_separation(wait_context& root_wait_ctx, task_group_context& context, const F1… in invoke_recursive_separation()
157 void invoke_recursive_separation(wait_context& root_wait_ctx, task_group_context& context, const F1… in invoke_recursive_separation()
171 void invoke_recursive_separation(wait_context& root_wait_ctx, task_group_context& context, in invoke_recursive_separation()
181 void parallel_invoke_impl(task_group_context& context, const Fs&... fs) { in parallel_invoke_impl()
191 task_group_context context(PARALLEL_INVOKE); in parallel_invoke_impl()
H A Dparallel_for.h100 task_group_context context(PARALLEL_FOR); in run()
104 … run(const Range& range, const Body& body, Partitioner& partitioner, task_group_context& context) { in run()
268 void parallel_for( const Range& range, const Body& body, task_group_context& context ) { in __TBB_requires()
276 …ge& range, const Body& body, const simple_partitioner& partitioner, task_group_context& context ) { in __TBB_requires()
284 …ange& range, const Body& body, const auto_partitioner& partitioner, task_group_context& context ) { in __TBB_requires()
292 …ge& range, const Body& body, const static_partitioner& partitioner, task_group_context& context ) { in __TBB_requires()
300 … Range& range, const Body& body, affinity_partitioner& partitioner, task_group_context& context ) { in __TBB_requires()
397 void parallel_for(Index first, Index last, Index step, const Function& f, task_group_context &conte… in __TBB_requires()
428 void parallel_for(Index first, Index last, const Function& f, task_group_context &context) { in __TBB_requires()
440 … Index last, const Function& f, const auto_partitioner& partitioner, task_group_context &context) { in __TBB_requires()
[all …]
H A Dparallel_reduce.h76 void join(task_group_context* context) { in join()
149 task_group_context context(PARALLEL_REDUCE); in run()
242 void join(task_group_context* context) { in join()
295 task_group_context context(PARALLEL_REDUCE); in run()
470 void parallel_reduce( const Range& range, Body& body, task_group_context& context ) { in __TBB_requires()
578 task_group_context& context ) { in __TBB_requires()
604 const auto_partitioner& partitioner, task_group_context& context ) { in __TBB_requires()
630 affinity_partitioner& partitioner, task_group_context& context ) { in __TBB_requires()
728 task_group_context& context ) { in __TBB_requires()
738 const simple_partitioner& partitioner, task_group_context& context ) { in __TBB_requires()
[all …]
H A Dcollaborative_call_once.h103 task_group_context context{ task_group_context::bound, in alignas()
104 task_group_context::default_traits | task_group_context::concurrent_wait }; in alignas()
123 task_group_context stub_context; in alignas()
H A Dparallel_for_each.h196 feeder_impl(const Body& body, wait_context& w_context, task_group_context &context) in feeder_impl()
204 task_group_context& my_execution_context;
316 task_group_context& my_execution_context;
329 wait_context& w_context, task_group_context& e_context,
377 task_group_context& my_execution_context;
459 feeder_holder( wait_context&, task_group_context&, const Body& ) {}
467 feeder_holder( wait_context& w_context, task_group_context& context, const Body& body )
493 task_group_context& my_execution_context;
662 task_group_context context(PARALLEL_FOR_EACH);
688 void parallel_for_each(Range& rng, const Body& body, task_group_context& context) {
[all …]
H A Dparallel_pipeline.h33 TBB_EXPORT void __TBB_EXPORTED_FUNC parallel_pipeline(task_group_context&, std::size_t, const d1::f…
53 friend void parallel_pipeline( size_t, const filter<void,void>&, task_group_context& );
119 …_t max_number_of_live_tokens, const filter<void,void>& filter_chain, task_group_context& context) { in parallel_pipeline()
126 task_group_context context; in parallel_pipeline()
/oneTBB/include/oneapi/tbb/detail/
H A D_task.h44 class task_group_context; variable
50 TBB_EXPORT void __TBB_EXPORTED_FUNC spawn(d1::task& t, d1::task_group_context& ctx);
52 …ED_FUNC execute_and_wait(d1::task& t, d1::task_group_context& t_ctx, d1::wait_context&, d1::task_g…
53 TBB_EXPORT void __TBB_EXPORTED_FUNC wait(d1::wait_context&, d1::task_group_context& ctx);
55 TBB_EXPORT d1::task_group_context* __TBB_EXPORTED_FUNC current_context();
151 task_group_context* context{};
156 inline task_group_context* context(const execution_data& ed) { in context()
180 inline void spawn(task& t, task_group_context& ctx) { in spawn()
185 inline void spawn(task& t, task_group_context& ctx, slot_id id) { in spawn()
190 inline void execute_and_wait(task& t, task_group_context& t_ctx, wait_context& wait_ctx, task_group… in execute_and_wait()
[all …]
H A D_task_handle.h30 namespace d1 { class task_group_context; class wait_context; struct execution_data; } variable
38 d1::task_group_context& m_ctx;
49 …task_handle_task(d1::wait_context& wo, d1::task_group_context& ctx, d1::small_object_allocator& al… in task_handle_task()
60 d1::task_group_context& ctx() const { return m_ctx; } in ctx()
97 static d1::task_group_context& ctx_of(task_handle& th) { in ctx_of()
/oneTBB/doc/main/tbb_userguide/
H A DCancellation_and_Nested_Parallelism.rst8 and skipping details of ``task_group_context``. This topic explains
15 associated with a ``task_group_context`` created by the algorithm.
16 Nested oneTBB algorithms create a tree of these ``task_group_context``
17 objects. Cancelling a ``task_group_context`` cancels all of its child
18 ``task_group_context`` objects, and transitively all its descendants.
27 ``task_group_context``.
34 Tree of task_group_context
86 construct an 'isolated' ``task_group_context`` on the stack and pass it
103 task_group_context root(task_group_context::isolated);
119 ``task_group_context`` ``root`` protects the inner loop from downwards
H A DFloating_Point_Settings.rst9 * The ``task_group_context`` class has a method to capture the current floating-point settings.
18 task_group_context ctx( task_group_context::isolated,
19 task_group_context::default_traits | task_group_context::fp_settings );
26 task_group_context ctx;
H A Dcancel_a_graph.rst8 graph using an explicit task_group_context, and then call
16 task_group_context t;
50 You can also get the task_group_context that a node belongs to from
84 You can get the task_group_context from a node's body even if the graph
H A DCancellation_Without_An_Exception.rst8 The part ``current_context()`` references the ``task_group_context*`` of the currently executing ta…
9 Calling ``cancel_group_execution()`` cancels all tasks in its ``task_group_context``, which is expl…
10 …ns ``true`` if it actually causes cancellation, ``false`` if the ``task_group_context`` was alread…
/oneTBB/test/tbb/
H A Dtest_tbb_header.cpp234 TestTypeDefinitionPresence( task_group_context ); in DefinitionPresence()
257 …TestFuncDefinitionPresence( parallel_invoke, (const Body&, const Body&, tbb::task_group_context&),… in DefinitionPresence()
258 …ionPresence( parallel_for_each, (const intarray&, const Body1a&, tbb::task_group_context&), void ); in DefinitionPresence()
259 …llel_for, (int, int, const Body1&, const tbb::auto_partitioner&, tbb::task_group_context&), void ); in DefinitionPresence()
260 …TestFuncDefinitionPresence( parallel_for, (int, int, const Body1&, tbb::task_group_context&), void… in DefinitionPresence()
261 … tbb::blocked_range<int>&, Body2&, const tbb::auto_partitioner&, tbb::task_group_context&), void ); in DefinitionPresence()
262 …sence( parallel_reduce, (const tbb::blocked_range<int>&, Body2&, tbb::task_group_context&), void ); in DefinitionPresence()
263 …bb::blocked_range<int>&, Body2&, const tbb::simple_partitioner&, tbb::task_group_context&), void ); in DefinitionPresence()
264 …l_deterministic_reduce, (const tbb::blocked_range<int>&, Body2&, tbb::task_group_context&), void ); in DefinitionPresence()
H A Dtest_eh_algorithms.cpp282 tbb::task_group_context ctx(tbb::task_group_context::isolated); in operator ()()
338 tbb::task_group_context ctx(tbb::task_group_context::isolated); in operator ()()
501 tbb::task_group_context &my_ctx;
630 tbb::task_group_context& tgc;
895 tbb::task_group_context ctx(tbb::task_group_context::isolated); in operator ()()
945 tbb::task_group_context ctx(tbb::task_group_context::isolated); in operator ()()
1163 tbb::task_group_context &my_ctx;
1181 tbb::task_group_context ctx; in TestCancelation1_parallel_for_each()
1438 tbb::task_group_context ctx(tbb::task_group_context::isolated); in operator ()()
1511 tbb::task_group_context ctx(tbb::task_group_context::isolated); in operator ()()
[all …]
H A Dtest_task.cpp97 tbb::task_group_context test_context; in test_cancellation_on_exception()
143 tbb::task_group_context test_context;
320 tbb::task_group_context& my_test_ctx;
331 tbb::task_group_context test_context;
383 tbb::task_group_context test_context;
469 tbb::task_group_context test_context;
510 tbb::task_group_context test_context;
583 tbb::task_group_context test_context;
668 tbb::task_group_context test_context;
728 tbb::task_group_context& my_ctx;
[all …]
/oneTBB/examples/task_arena/fractal/
H A Dfractal.hpp51 void render(oneapi::tbb::task_group_context &context);
64 void run(oneapi::tbb::task_group_context &context);
108 oneapi::tbb::task_group_context context[2];

123