Home
last modified time | relevance | path

Searched refs:control (Results 1 – 25 of 47) sorted by relevance

12

/oneTBB/test/conformance/
H A Dconformance_parallel_scan.cpp91 std::vector<int> control(size);
96 control[i] = control[i-1] + input[i];
98 control[i] = input[i];
102 CHECK((control == output));
111 std::vector<std::size_t> control(size);
116 control[i] = control[i-1]+input[i];
118 control[i] = input[i];
136 CHECK((control==output));
H A Dconformance_parallel_sort.cpp41 …oneapi::tbb::global_control control(oneapi::tbb::global_control::max_allowed_parallelism, concurre…
55 …oneapi::tbb::global_control control(oneapi::tbb::global_control::max_allowed_parallelism, concurre…
69 …oneapi::tbb::global_control control(oneapi::tbb::global_control::max_allowed_parallelism, concurre…
83 …oneapi::tbb::global_control control(oneapi::tbb::global_control::max_allowed_parallelism, concurre…
H A Dconformance_parallel_pipeline.cpp46 U operator()( oneapi::tbb::flow_control& control ) const { in operator ()()
48 control.stop(); in operator ()()
104 TestSingleFilter([]( oneapi::tbb::flow_control& control ) { in TestSingleFilterLambda() argument
106 control.stop(); in TestSingleFilterLambda()
112 TestSingleFilter([]( oneapi::tbb::flow_control& control ) { in TestSingleFilterLambda() argument
114 control.stop(); in TestSingleFilterLambda()
281 …oneapi::tbb::global_control control(oneapi::tbb::global_control::max_allowed_parallelism, concurre…
H A Dconformance_parallel_invoke.cpp71 …oneapi::tbb::global_control control(oneapi::tbb::global_control::max_allowed_parallelism, concurre… in correctness_test() local
147 …oneapi::tbb::global_control control(oneapi::tbb::global_control::max_allowed_parallelism, concurre…
196 …oneapi::tbb::global_control control(oneapi::tbb::global_control::max_allowed_parallelism, concurre…
H A Dconformance_parallel_for_each.cpp26 …oneapi::tbb::global_control control(oneapi::tbb::global_control::max_allowed_parallelism, concurre…
66 …oneapi::tbb::global_control control(oneapi::tbb::global_control::max_allowed_parallelism, concurre… in WorkProducingTest() local
H A Dconformance_parallel_reduce.cpp98 …oneapi::tbb::global_control control(oneapi::tbb::global_control::max_allowed_parallelism, concurre…
110 …oneapi::tbb::global_control control(oneapi::tbb::global_control::max_allowed_parallelism, concurre…
/oneTBB/test/tbb/
H A Dtest_parallel_pipeline.cpp124 control.stop(); in operator ()()
137 U* operator()(tbb::flow_control& control) const { in operator ()()
141 control.stop(); in operator ()()
163 control.stop(); in operator ()()
176 operator()(tbb::flow_control& control ) const { in operator ()()
180 control.stop(); in operator ()()
408 control.stop(); in run_function_spec()
511 control.stop(); in run_lambdas_test()
529 control.stop(); in run_lambdas_test()
552 control.stop(); in run_lambdas_test()
[all …]
H A Dtest_parallel_for_each.cpp128 … tbb::global_control control(tbb::global_control::max_allowed_parallelism, concurrency_level);
142 … tbb::global_control control(tbb::global_control::max_allowed_parallelism, concurrency_level);
156 … tbb::global_control control(tbb::global_control::max_allowed_parallelism, concurrency_level);
183 … tbb::global_control control(tbb::global_control::max_allowed_parallelism, concurrency_level);
H A Dtest_parallel_sort.cpp181 … tbb::global_control control(tbb::global_control::max_allowed_parallelism, concurrency_level); in parallel_sort_test_suite() local
193 … tbb::global_control control(tbb::global_control::max_allowed_parallelism, concurrency_level); in parallel_sort_test_suite() local
372 … tbb::global_control control(tbb::global_control::max_allowed_parallelism, concurrency_level);
H A Dtest_parallel_scan.cpp491 … tbb::global_control control(tbb::global_control::max_allowed_parallelism, concurrency_level);
510 … tbb::global_control control(tbb::global_control::max_allowed_parallelism, concurrency_level);
529 … tbb::global_control control(tbb::global_control::max_allowed_parallelism, concurrency_level);
550 … tbb::global_control control(tbb::global_control::max_allowed_parallelism, concurrency_level);
H A Dtest_parallel_invoke.cpp40 tbb::global_control control(tbb::global_control::max_allowed_parallelism, concurrency_limit);
/oneTBB/src/tbb/
H A Dthreading_control.cpp201 threading_control* control = g_threading_control; in get_threading_control() local
202 if (control) { in get_threading_control()
203 control->add_ref(is_public); in get_threading_control()
206 return control; in get_threading_control()
289 threading_control* control{nullptr}; in register_public_reference() local
291 control = get_threading_control(/*public = */ true); in register_public_reference()
292 if (!control) { in register_public_reference()
295 control = create_threading_control(); in register_public_reference()
298 return control; in register_public_reference()
H A Darena.cpp249 arena::arena(threading_control* control, unsigned num_slots, unsigned num_reserved_slots, unsigned … in arena() argument
253 my_threading_control = control; in arena()
286 arena& arena::allocate_arena(threading_control* control, unsigned num_slots, unsigned num_reserved_… in allocate_arena() argument
298 arena(control, num_slots, num_reserved_slots, priority_level); in allocate_arena()
451 arena& arena::create(threading_control* control, unsigned num_slots, unsigned num_reserved_slots, u… in create() argument
455 arena& a = arena::allocate_arena(control, num_slots, num_reserved_slots, arena_priority_level); in create()
456 a.my_tc_client = control->create_client(a); in create()
458 control->publish_client(a.my_tc_client, constraints); in create()
H A Darena.h284 …arena(threading_control* control, unsigned max_num_workers, unsigned num_reserved_slots, unsigned …
287 …static arena& allocate_arena(threading_control* control, unsigned num_slots, unsigned num_reserved…
290 …static arena& create(threading_control* control, unsigned num_slots, unsigned num_reserved_slots, …
H A Dthreading_control.h79 …atic cache_aligned_unique_ptr<thread_dispatcher> make_thread_dispatcher(threading_control& control,
/oneTBB/doc/main/tbb_userguide/
H A DFlow_Graph_resource_tips.rst7 You may want to control the number of messages allowed to enter parts of
8 your graph, or control the maximum number of tasks in the work pool.
H A Duse_concurrency_limits.rst7 To control the number of instances of a single node, you can use the
29 For example, you can control the number of big objects in flight in a
H A Dcancelling_nested_parallelism.rst17 As with all of the library's nested parallelism, you can control
H A DMutual_Exclusion.rst100 because if the protected region threw an exception, control would skip
103 the protected region was exited by normal control flow or an exception.
H A DControlling_Chunking_os.rst8 the most control over chunking, you specify both.
48 There is also an intermediate level of control where you specify the
H A DMapping_Nodes2Tasks.rst42 try_put return control to the calling thread quickly, after either
/oneTBB/include/oneapi/tbb/detail/
H A D_pipeline_filters.h258 flow_control control;
259 output_pointer temp_output = output_helper::create_token(my_body(control));
260 if(control.is_pipeline_stopped) {
302 flow_control control;
303 my_body(control);
304 void* output = control.is_pipeline_stopped ? nullptr : (void*)(std::intptr_t)-1;
/oneTBB/
H A DLICENSE.txt16 other entities that control, are controlled by, or are under common
17 control with that entity. For the purposes of this definition,
18 "control" means (i) the power, direct or indirect, to cause the
56 communication on electronic mailing lists, source code control systems,
/oneTBB/src/tbb/def/
H A Dlin64-tbb.def130 /* Global control (global_control.cpp) */
H A Dlin32-tbb.def130 /* Global control (global_control.cpp) */

12