Lines Matching refs:tbb
28 tbb::global_control s0(tbb::global_control::thread_stack_size, 1*MB); in TestStackSizeSimpleControl()
31 tbb::global_control s1(tbb::global_control::thread_stack_size, 8*MB); in TestStackSizeSimpleControl()
33 … ASSERT(8*MB == tbb::global_control::active_value(tbb::global_control::thread_stack_size), NULL); in TestStackSizeSimpleControl()
35 … ASSERT(1*MB == tbb::global_control::active_value(tbb::global_control::thread_stack_size), NULL); in TestStackSizeSimpleControl()
50 tbb::global_control s1(tbb::global_control::thread_stack_size, (1+id)*MB); in operator ()()
54 …ASSERT(num_threads*MB == tbb::global_control::active_value(tbb::global_control::thread_stack_size)… in operator ()()
68 tbb::global_control s(tbb::global_control::max_allowed_parallelism, parallelism); in RunWorkersLimited()
74 : ( tbb::tbb_thread::hardware_concurrency()==1? 1 : parallelism ); in RunWorkersLimited()
79 tbb::task_scheduler_init init;
81 …blocking_task_scheduler_init(int num_threads = tbb::task_scheduler_init::automatic) : init(num_thr… in blocking_task_scheduler_init()
91 size_t active = tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism); in TSI_and_RunWorkers()
101 tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism); in TestWorkers()
102 ASSERT(max(2U, tbb::tbb_thread::hardware_concurrency()) == max_parallelism, NULL); in TestWorkers()
104 const unsigned h_c = tbb::tbb_thread::hardware_concurrency(); in TestWorkers()
105 tbb::global_control c(tbb::global_control::max_allowed_parallelism, curr_par); in TestWorkers()
106 size_t v = tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism); in TestWorkers()
109 TSI_and_RunWorkers(tbb::task_scheduler_init::automatic, min(h_c, curr_par), curr_par); in TestWorkers()
117 tbb::global_control c1(tbb::global_control::max_allowed_parallelism, curr_par+1); in TestWorkers()
118 v = tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism); in TestWorkers()
124 ASSERT(tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism) in TestWorkers()
131 tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism); in TestWorkersConstraints()
134 tbb::global_control c(tbb::global_control::max_allowed_parallelism, max_parallelism-1); in TestWorkersConstraints()
136 tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism), in TestWorkersConstraints()
138 tbb::global_control c1(tbb::global_control::max_allowed_parallelism, max_parallelism-2); in TestWorkersConstraints()
140 tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism), in TestWorkersConstraints()
147 RunWorkersLimited(tbb::task_scheduler_init::automatic, num, wait==1); in TestWorkersConstraints()
149 RunWorkersLimited(tbb::task_scheduler_init::automatic, num, wait==1); in TestWorkersConstraints()
161 tbb::parallel_for(0, LOOP_ITERS, DummyBody(), tbb::simple_partitioner()); in RunParallelWork()
177 tbb::global_control c(tbb::global_control::max_allowed_parallelism, 8); in operator ()()
194 tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism); in TestAutoInit()
195 const unsigned expected_threads = tbb::tbb_thread::hardware_concurrency()==1? in TestAutoInit()
198 ASSERT(tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism) in TestAutoInit()
202 tbb::global_control s(tbb::global_control::max_allowed_parallelism, max_parallelism-1); in TestAutoInit()
217 tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism); in TestInvalidParallelism()
219 tbb::set_assertion_handler( AssertionFailureHandler ); in TestInvalidParallelism()
220 TRY_BAD_EXPR( tbb::global_control c(tbb::global_control::max_allowed_parallelism, 0), in TestInvalidParallelism()
222 tbb::set_assertion_handler( ReportError ); in TestInvalidParallelism()
223 ASSERT(tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism) in TestInvalidParallelism()
228 tbb::global_control c(tbb::global_control::max_allowed_parallelism, P); in TestInvalidParallelism()
229 ASSERT(tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism) in TestInvalidParallelism()
231 tbb::set_assertion_handler( AssertionFailureHandler ); in TestInvalidParallelism()
232 TRY_BAD_EXPR( tbb::global_control cZ(tbb::global_control::max_allowed_parallelism, 0), in TestInvalidParallelism()
234 tbb::set_assertion_handler( ReportError ); in TestInvalidParallelism()
235 ASSERT(tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism) in TestInvalidParallelism()
238 ASSERT(tbb::global_control::active_value(tbb::global_control::max_allowed_parallelism) in TestInvalidParallelism()
252 size_t default_ss = tbb::global_control::active_value(tbb::global_control::thread_stack_size); in TestTooBigStack()
258 … size_t curr_ss = tbb::global_control::active_value(tbb::global_control::thread_stack_size); in TestTooBigStack()
259 tbb::set_assertion_handler( AssertionFailureHandler ); in TestTooBigStack()
260 …TRY_BAD_EXPR( tbb::global_control s1(tbb::global_control::thread_stack_size, stack_sizes[i]), "Sta… in TestTooBigStack()
261 tbb::set_assertion_handler( ReportError ); in TestTooBigStack()
262 …ASSERT(curr_ss == tbb::global_control::active_value(tbb::global_control::thread_stack_size), "Chan… in TestTooBigStack()
266 tbb::global_control s1(tbb::global_control::thread_stack_size, stack_sizes[i]); in TestTooBigStack()
267 …size_t actual_stack_sz = tbb::global_control::active_value(tbb::global_control::thread_stack_size); in TestTooBigStack()
289 class FFTask: public tbb::task {
290 tbb::atomic<int> *counter;
291 tbb::task* execute() __TBB_override { in execute()
296 FFTask(tbb::atomic<int> *counter_) : counter(counter_) {} in FFTask()
299 class WaiterTask: public tbb::task {
300 tbb::atomic<bool> *flag;
301 tbb::task* execute() __TBB_override { in execute()
307 WaiterTask(tbb::atomic<bool> *flag_) : flag(flag_) {} in WaiterTask()
310 class WorkAndEnqueueTask: public tbb::task {
311 tbb::atomic<int> *counter;
312 tbb::atomic<bool> *signalToLeave;
313 tbb::task* execute() __TBB_override { in execute()
317 FFTask* t = new( tbb::task::allocate_root() ) FFTask(counter); in execute()
318 tbb::task::enqueue(*t); in execute()
325 WorkAndEnqueueTask(tbb::atomic<int> *counter_, tbb::atomic<bool> *signal_) in WorkAndEnqueueTask()
330 tbb::priority_t getPriorityByInt(int i) { in getPriorityByInt()
331 return i%3==0? tbb::priority_low : (i%3==1? tbb::priority_normal : in getPriorityByInt()
332 tbb::priority_high); in getPriorityByInt()
339 FFTask* t = new( tbb::task::allocate_root() ) FFTask(cnt); in enqTasks()
341 tbb::priority_t p = getPriorityByInt(i+id); in enqTasks()
342 tbb::task::enqueue(*t, p); in enqTasks()
344 tbb::internal::suppress_unused_warning(id); in enqTasks()
345 tbb::task::enqueue(*t); in enqTasks()
352 tbb::atomic<int> *cnt;
354 FFTasksRun(Harness::SpinBarrier *b, tbb::atomic<int> *c) : in FFTasksRun()
369 tbb::atomic<int> flag; in TestTaskEnqueue()
370 tbb::atomic<bool> taskDoneFlag; in TestTaskEnqueue()
375 WaiterTask* w = new( tbb::task::allocate_root() ) WaiterTask(&taskDoneFlag); in TestTaskEnqueue()
376 tbb::task::enqueue(*w); in TestTaskEnqueue()
378 tbb::global_control c(tbb::global_control::max_allowed_parallelism, 1); in TestTaskEnqueue()
381 FFTask* t = new( tbb::task::allocate_root() ) FFTask(&flag); in TestTaskEnqueue()
382 tbb::task::enqueue(*t); in TestTaskEnqueue()
388 tbb::atomic<int> flag; in TestTaskEnqueue()
389 tbb::atomic<bool> taskDoneFlag; in TestTaskEnqueue()
393 WaiterTask* w = new( tbb::task::allocate_root() ) WaiterTask(&taskDoneFlag); in TestTaskEnqueue()
394 tbb::task::enqueue(*w); in TestTaskEnqueue()
397 tbb::global_control c(tbb::global_control::max_allowed_parallelism, 1); in TestTaskEnqueue()
399 FFTask* t = new( tbb::task::allocate_root() ) FFTask(&flag); in TestTaskEnqueue()
400 tbb::task::enqueue(*t); in TestTaskEnqueue()
406 tbb::atomic<int> flag; in TestTaskEnqueue()
409 tbb::global_control c(tbb::global_control::max_allowed_parallelism, 1); in TestTaskEnqueue()
411 FFTask* t = new( tbb::task::allocate_root() ) FFTask(&flag); in TestTaskEnqueue()
412 tbb::task::enqueue(*t); in TestTaskEnqueue()
418 tbb::atomic<int> flag; in TestTaskEnqueue()
421 FFTask* t = new( tbb::task::allocate_root() ) FFTask(&flag); in TestTaskEnqueue()
422 tbb::task::enqueue(*t); in TestTaskEnqueue()
423 tbb::global_control c(tbb::global_control::max_allowed_parallelism, 1); in TestTaskEnqueue()
429 tbb::global_control c(tbb::global_control::max_allowed_parallelism, 1); in TestTaskEnqueue()
433 tbb::atomic<int> flag; in TestTaskEnqueue()
436 FFTask* t = new( tbb::task::allocate_root() ) FFTask(&flag); in TestTaskEnqueue()
437 tbb::task::enqueue(*t); in TestTaskEnqueue()
442 tbb::atomic<int> flag; in TestTaskEnqueue()
448 FFTask* t = new( tbb::task::allocate_root() ) FFTask(&flag); in TestTaskEnqueue()
450 const tbb::priority_t p = getPriorityByInt(i); in TestTaskEnqueue()
451 tbb::task::enqueue(*t, p); in TestTaskEnqueue()
453 tbb::task::enqueue(*t); in TestTaskEnqueue()
468 tbb::atomic<int> counter; in TestTaskEnqueue()
480 tbb::atomic<bool> signalToLeave; in TestTaskEnqueue()
484 WorkAndEnqueueTask *t = new( tbb::task::allocate_root() ) in TestTaskEnqueue()
486 tbb::task::enqueue(*t); in TestTaskEnqueue()
495 class CountWorkersTask: public tbb::task {
496 tbb::atomic<bool> *flag;
498 static tbb::combinable<size_t> uniqThreads;
500 tbb::task* execute() __TBB_override { in execute()
507 CountWorkersTask(tbb::atomic<bool> *flag_) : flag(flag_) {} in CountWorkersTask()
513 tbb::combinable<size_t> CountWorkersTask::uniqThreads;
515 tbb::atomic<int> activeArenas;
517 class ArenaObserver: public tbb::task_scheduler_observer {
519 ArenaObserver() : tbb::task_scheduler_observer(/*local=*/true) { in ArenaObserver()
542 tbb::atomic<bool> flag; in operator ()()
545 CountWorkersTask* t = new( tbb::task::allocate_root() ) in operator ()()
548 tbb::task::enqueue(*t); in operator ()()
555 tbb::atomic<int> *counter;
557 ArenaRun(tbb::atomic<int> *counter_) : counter(counter_) {} in ArenaRun()
565 tbb::task_arena *arena;
567 tbb::atomic<int> *counter;
569 ArenaUserRun(tbb::task_arena *a, Harness::SpinBarrier *b, tbb::atomic<int> *c) : in ArenaUserRun()
584 tbb::global_control c(tbb::global_control::max_allowed_parallelism, 1); in TestConcurrentArenas()
601 tbb::atomic<int> counter; in TestConcurrentArenas()
605 tbb::task_arena arena(2); in TestConcurrentArenas()
615 tbb::atomic<int> counter; in TestParallelismRestored()
621 ASSERT(tbb::this_task_arena::max_concurrency() == P, NULL); in TestParallelismRestored()
622 tbb::global_control s(tbb::global_control::max_allowed_parallelism, 1); in TestParallelismRestored()
626 FFTask* t = new( tbb::task::allocate_root() ) FFTask(&counter); in TestParallelismRestored()
627 tbb::task::enqueue(*t); in TestParallelismRestored()
629 ASSERT(tbb::this_task_arena::max_concurrency() == P, NULL); in TestParallelismRestored()
631 ASSERT(tbb::this_task_arena::max_concurrency() == P, NULL); in TestParallelismRestored()
645 tbb::combinable<size_t> uniqThreads; in operator ()()
656 tbb::atomic<int> flag; in operator ()()
658 FFTask* t = new( tbb::task::allocate_root() ) FFTask(&flag); in operator ()()
659 tbb::task::enqueue(*t); in operator ()()
674 tbb::global_control c(tbb::global_control::max_allowed_parallelism, 1); in TestNoUnwantedEnforced()
687 tbb::global_control c(tbb::global_control::max_allowed_parallelism, 1); in operator ()()
694 tbb::global_control c(tbb::global_control::max_allowed_parallelism, 2); in operator ()()
703 tbb::global_control c(tbb::global_control::max_allowed_parallelism, 1); in operator ()()
730 tbb::task_scheduler_init tsi(2); in TestForgottenEnqueuedTasks()
731 tbb::atomic<int> counter; in TestForgottenEnqueuedTasks()
732 tbb::atomic<bool> waitFlag; in TestForgottenEnqueuedTasks()
736 tbb::task &r = *new( tbb::task::allocate_root() ) tbb::empty_task; in TestForgottenEnqueuedTasks()
739 tbb::task &t = *new( r.allocate_child() ) WaiterTask(&waitFlag); in TestForgottenEnqueuedTasks()
740 tbb::task::spawn(t); in TestForgottenEnqueuedTasks()
743 FFTask* t = new( tbb::task::allocate_root() ) FFTask(&counter); in TestForgottenEnqueuedTasks()
744 tbb::task::enqueue(*t, tbb::priority_low); in TestForgottenEnqueuedTasks()
746 tbb::global_control c(tbb::global_control::max_allowed_parallelism, 1); in TestForgottenEnqueuedTasks()
752 tbb::task::destroy(r); in TestForgottenEnqueuedTasks()
763 const unsigned h_c = tbb::tbb_thread::hardware_concurrency(); in TestMain()
766 tbb::task_scheduler_init t(h_c+1); in TestMain()
782 size_t default_ss = tbb::global_control::active_value(tbb::global_control::thread_stack_size); in TestMain()
791 …ASSERT(default_ss == tbb::global_control::active_value(tbb::global_control::thread_stack_size), NU… in TestMain()