| /oneTBB/test/conformance/ |
| H A D | conformance_global_control.cpp | 34 oneapi::tbb::global_control s0(oneapi::tbb::global_control::thread_stack_size, 1*MB); in TestStackSizeSimpleControl() 37 oneapi::tbb::global_control s1(oneapi::tbb::global_control::thread_stack_size, 8*MB); in TestStackSizeSimpleControl() 52 oneapi::tbb::global_control s1(oneapi::tbb::global_control::thread_stack_size, (1+id)*MB); in operator ()() 69 … oneapi::tbb::global_control s(oneapi::tbb::global_control::max_allowed_parallelism, parallelism); in RunWorkersLimited() 82 … oneapi::tbb::global_control::active_value(oneapi::tbb::global_control::max_allowed_parallelism); in TestWorkersConstraints() 113 … oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, 8); in operator ()() 233 oneapi::tbb::global_control c1(oneapi::tbb::global_control::terminate_on_exception, 1); 236 oneapi::tbb::global_control c2(oneapi::tbb::global_control::terminate_on_exception, 0); 251 …oneapi::tbb::global_control* ctl1 = new oneapi::tbb::global_control(oneapi::tbb::global_control::m… 252 …oneapi::tbb::global_control* ctl2 = new oneapi::tbb::global_control(oneapi::tbb::global_control::m… [all …]
|
| H A D | conformance_parallel_sort.cpp | 41 …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 D | conformance_parallel_invoke.cpp | 71 …oneapi::tbb::global_control control(oneapi::tbb::global_control::max_allowed_parallelism, concurre… in correctness_test() 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 D | conformance_parallel_for_each.cpp | 26 …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()
|
| H A D | conformance_parallel_reduce.cpp | 98 …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…
|
| H A D | conformance_input_node.cpp | 173 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, 228 oneapi::tbb::global_control control(oneapi::tbb::global_control::max_allowed_parallelism, 1);
|
| /oneTBB/src/tbb/ |
| H A D | global_control.cpp | 38 bool operator()(const d1::global_control* lhs, const d1::global_control* rhs) const; 49 …std::set<d1::global_control*, control_storage_comparator, tbb_allocator<d1::global_control*>> my_l… 167 …bool control_storage_comparator::operator()(const d1::global_control* lhs, const d1::global_contro… in operator ()() 173 return d1::global_control::active_value(d1::global_control::terminate_on_exception) == 1; in terminate_on_exception() 189 static void create(d1::global_control& gc) { in create() 202 static void destroy(d1::global_control& gc) { in destroy() 235 static bool is_present(d1::global_control& gc) { in is_present() 249 void __TBB_EXPORTED_FUNC create(d1::global_control& gc) { in create() 252 void __TBB_EXPORTED_FUNC destroy(d1::global_control& gc) { in destroy() 256 bool remove_and_check_if_empty(d1::global_control& gc) { in remove_and_check_if_empty() [all …]
|
| H A D | threading_control.cpp | 31 std::size_t global_control_active_value_unsafe(d1::global_control::parameter); 43 …unsigned workers_app_limit = global_control_active_value_unsafe(global_control::max_allowed_parall… in calculate_workers_limits() 52 … unsigned soft_limit = global_control_active_value_unsafe(global_control::max_allowed_parallelism); in calc_workers_soft_limit() 78 …stack_size_type stack_size = global_control_active_value_unsafe(global_control::thread_stack_size); in make_thread_dispatcher() 224 if (global_control_active_value_unsafe(global_control::scheduler_handle)) { in create_threading_control()
|
| H A D | governor.cpp | 47 bool remove_and_check_if_empty(d1::global_control& gc); 48 bool is_present(d1::global_control& gc); 267 …handle.m_ctl = new(allocate_memory(sizeof(global_control))) global_control(global_control::schedul… in get() 272 handle.m_ctl->~global_control(); in release_impl()
|
| /oneTBB/doc/main/tbb_userguide/Migration_Guide/ |
| H A D | Task_Scheduler_Init.rst | 25 * `oneapi::tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism) 36 * `tbb::global_control(tbb::global_control::max_allowed_parallelism, /* max_concurrency */) 81 #include <oneapi/tbb/global_control.h> 95 … oneapi::tbb::global_control global_limit(oneapi::tbb::global_control::max_allowed_parallelism, 2); 100 …int thread_limit = oneapi::tbb::global_control::active_value(oneapi::tbb::global_control::max_allo… 107 …int thread_limit = oneapi::tbb::global_control::active_value(oneapi::tbb::global_control::max_allo… 118 Use `oneapi::tbb::global_control(oneapi::tbb::global_control::thread_stack_size, /* stack_size */) 125 #include <oneapi/tbb/global_control.h> 131 …oneapi::tbb::global_control global_limit(tbb::global_control::thread_stack_size, 16 * 1024 * 1024); 149 #include <oneapi/tbb/global_control.h>
|
| /oneTBB/include/oneapi/tbb/ |
| H A D | global_control.h | 35 class global_control; variable 40 TBB_EXPORT void __TBB_EXPORTED_FUNC create(d1::global_control&); 41 TBB_EXPORT void __TBB_EXPORTED_FUNC destroy(d1::global_control&); 53 class global_control { 63 global_control(parameter p, std::size_t value) : in global_control() function 80 ~global_control() { in ~global_control() 160 global_control* m_ctl{nullptr}; 191 using detail::d1::global_control;
|
| /oneTBB/python/tbb/ |
| H A D | api.i | 87 std::unique_ptr<global_control> g( 88 (global_control::active_value(global_control::max_allowed_parallelism) < unsigned(threads))? 89 new global_control(global_control::max_allowed_parallelism, threads) : nullptr); 142 class global_control { 149 global_control(parameter param, size_t value); 150 ~global_control();
|
| /oneTBB/test/tbb/ |
| H A D | test_task_group.cpp | 771 tbb::global_control limit(tbb::global_control::max_allowed_parallelism, p); 782 tbb::global_control limit(tbb::global_control::max_allowed_parallelism, p); 792 tbb::global_control limit(tbb::global_control::max_allowed_parallelism, p); 805 tbb::global_control limit(tbb::global_control::max_allowed_parallelism, p); 815 tbb::global_control limit(tbb::global_control::max_allowed_parallelism, p); 839 tbb::global_control limit(tbb::global_control::max_allowed_parallelism, p); 850 tbb::global_control limit(tbb::global_control::max_allowed_parallelism, p); 860 tbb::global_control limit(tbb::global_control::max_allowed_parallelism, p); 870 tbb::global_control limit(tbb::global_control::max_allowed_parallelism, p); 880 tbb::global_control limit(tbb::global_control::max_allowed_parallelism, p); [all …]
|
| H A D | test_parallel_for_each.cpp | 128 … 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 D | test_parallel_sort.cpp | 181 … tbb::global_control control(tbb::global_control::max_allowed_parallelism, concurrency_level); in parallel_sort_test_suite() 193 … tbb::global_control control(tbb::global_control::max_allowed_parallelism, concurrency_level); in parallel_sort_test_suite() 372 … tbb::global_control control(tbb::global_control::max_allowed_parallelism, concurrency_level);
|
| H A D | test_parallel_scan.cpp | 491 … 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 D | test_parallel_invoke.cpp | 40 tbb::global_control control(tbb::global_control::max_allowed_parallelism, concurrency_limit);
|
| /oneTBB/examples/parallel_reduce/pi/ |
| H A D | pi.cpp | 47 static std::unique_ptr<tbb::global_control> gc; 50 gc.reset(new tbb::global_control(tbb::global_control::max_allowed_parallelism, p)); in threading()
|
| /oneTBB/examples/concurrent_hash_map/count_strings/ |
| H A D | count_strings.cpp | 270 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, p); in main() 278 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, 1); in main() 284 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, in main()
|
| /oneTBB/examples/parallel_pipeline/square/ |
| H A D | square.cpp | 251 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, p); in main() 260 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, 1); in main() 267 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, in main()
|
| /oneTBB/examples/parallel_for/game_of_life/ |
| H A D | Evolution.cpp | 104 oneapi::tbb::global_control* pGlobControl = new oneapi::tbb::global_control( in Run() 105 oneapi::tbb::global_control::max_allowed_parallelism, nthread); in Run()
|
| /oneTBB/examples/concurrent_priority_queue/shortpath/ |
| H A D | shortpath.cpp | 213 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, in InitializeGraph() 264 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, in ResetGraph() 314 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, n_thr); in main()
|
| /oneTBB/examples/parallel_for_each/parallel_preorder/ |
| H A D | main.cpp | 67 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, p); in main()
|
| /oneTBB/examples/parallel_for/seismic/ |
| H A D | main.cpp | 107 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, in main()
|
| /oneTBB/examples/parallel_for/polygon_overlay/ |
| H A D | polyover.cpp | 158 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, in NaiveParallelOverlay() 428 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, in SplitParallelOverlay() 555 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, in SplitParallelOverlayCV() 690 oneapi::tbb::global_control c(oneapi::tbb::global_control::max_allowed_parallelism, in SplitParallelOverlayETS()
|