Home
last modified time | relevance | path

Searched refs:this_thread (Results 1 – 23 of 23) sorted by relevance

/oneTBB/test/common/
H A Dutils_concurrency_limit.h271 pthread_t this_thread = pthread_self(); in can_change_thread_priority() local
274 int err = pthread_getschedparam(this_thread, &old_policy, &old_params); in can_change_thread_priority()
280 err = pthread_setschedparam(this_thread, SCHED_FIFO, &params); in can_change_thread_priority()
282 err = pthread_setschedparam(this_thread, old_policy, &old_params); in can_change_thread_priority()
299 pthread_t this_thread = pthread_self(); in ~increased_priority_guard() local
300 int err = pthread_setschedparam(this_thread, in ~increased_priority_guard()
306 pthread_t this_thread = pthread_self(); in get_current_schedparam() local
309 int err = pthread_getschedparam(this_thread, &policy, &params); in get_current_schedparam()
315 pthread_t this_thread = pthread_self(); in increase_thread_priority() local
319 int err = pthread_setschedparam(this_thread, SCHED_FIFO, &params); in increase_thread_priority()
H A Dexception_handling.h30 std::thread::id g_Master = std::this_thread::get_id();
130 bool inMaster = (std::this_thread::get_id() == g_Master); in ThrowTestException()
169 if(g_Master == std::this_thread::get_id()) g_MasterExecuted = true; \
259 return std::this_thread::get_id() == g_Master; in IsMaster()
H A Dutils_yield.h29 using std::this_thread::yield;
H A Dspin_barrier.h49 std::this_thread::sleep_for(std::chrono::microseconds(count/100)); in SpinWaitWhile()
H A Dgraph_utils.h693 std::thread::id this_id = std::this_thread::get_id();
715 std::thread::id body_thread_id = std::this_thread::get_id();
745 std::thread::id this_id = std::this_thread::get_id();
H A Dutils.h355 std::this_thread::sleep_for( sleep_time );
/oneTBB/test/tbb/
H A Dtest_eh_algorithms.cpp389 g_Master = std::this_thread::get_id();
410 g_Master = std::this_thread::get_id();
431 g_Master = std::this_thread::get_id();
452 g_Master = std::this_thread::get_id();
473 g_Master = std::this_thread::get_id();
685 g_Master = std::this_thread::get_id();
706 g_Master = std::this_thread::get_id();
727 g_Master = std::this_thread::get_id();
924 g_Master = std::this_thread::get_id(); in Test3_parallel_for_each()
974 g_Master = std::this_thread::get_id(); in Test4_parallel_for_each()
[all …]
H A Dtest_resumable_tasks.cpp96 CHECK(thread_id == std::this_thread::get_id()); in operator ()()
118 tbb::task::suspend(SuspendBody(m_asyncActivity, std::this_thread::get_id())); in operator ()()
125 tbb::task::suspend(SuspendBody(m_asyncActivity, std::this_thread::get_id())); in operator ()()
320 tbb::task::suspend(SuspendBody(asyncActivity, std::this_thread::get_id())); in TestCleanupMaster()
338 tbb::task::suspend(SuspendBody(asyncActivity, std::this_thread::get_id())); in operator ()()
352 tbb::task::suspend(SuspendBody(asyncActivity, std::this_thread::get_id())); in TestNativeThread()
395 auto thread_id = std::this_thread::get_id(); in TestObservers()
397 CHECK(thread_id == std::this_thread::get_id()); in TestObservers()
H A Dtest_task.cpp400 auto thread_id = std::this_thread::get_id(); in __anon509d20bd0b02()
402 CHECK(thread_id == std::this_thread::get_id()); in __anon509d20bd0b02()
491 auto thread_id = std::this_thread::get_id(); in __anon509d20bd0e02()
493 CHECK(thread_id == std::this_thread::get_id()); in __anon509d20bd0e02()
546 auto thread_id = std::this_thread::get_id(); in __anon509d20bd1102()
548 CHECK(thread_id == std::this_thread::get_id()); in __anon509d20bd1102()
641 auto thread_id = std::this_thread::get_id(); in __anon509d20bd1a02()
643 CHECK(thread_id == std::this_thread::get_id()); in __anon509d20bd1a02()
780 std::this_thread::sleep_for(std::chrono::milliseconds(1)); in __anon509d20bd2102()
804 std::this_thread::sleep_for(std::chrono::milliseconds(1));
[all …]
H A Dtest_eh_flow_graph.cpp359 g_Master = std::this_thread::get_id(); in run_one_input_node_test()
500 g_Master = std::this_thread::get_id(); in run_one_functype_node_test()
805 g_Master = std::this_thread::get_id(); in run_one_continue_node_test()
925 g_Master = std::this_thread::get_id(); in run_one_buffer_node_test()
1059 g_Master = std::this_thread::get_id(); in run_one_sequencer_node_test()
1179 g_Master = std::this_thread::get_id(); in run_one_priority_queue_node_test()
1322 g_Master = std::this_thread::get_id(); in execute_test()
1432 g_Master = std::this_thread::get_id(); in execute_test()
1566 g_Master = std::this_thread::get_id(); in run_one_limiter_node_test()
1689 g_Master = std::this_thread::get_id(); in run_one_split_node_test()
[all …]
H A Dtest_partitioner.cpp73 std::this_thread::yield(); in test()
H A Dtest_continue_node.cpp258 : my_thread_id(std::this_thread::get_id()), my_count(count) in lightweight_policy_body()
268 std::thread::id body_thread_id = std::this_thread::get_id(); in operator ()()
H A Dtest_async_node.cpp64 place_wrapper( int v = 0 ) : value(v), thread_id(std::this_thread::get_id()) {} in place_wrapper()
524 if (std::this_thread::get_id() == my_main_tid) { in operator ()()
552 g, tbb::flow::unlimited, end_body_type(std::this_thread::get_id(), spin_barrier) in run()
H A Dtest_flow_graph_priorities.cpp438 do_nested_work<work_type>( /*tid=*/std::this_thread::get_id(), subrange ); in operator ()()
475 exec_tracker.prioritized_work_submitter = std::this_thread::get_id(); in do_node_work()
/oneTBB/examples/parallel_for/tachyon/src/
H A Dutil.cpp78 std::this_thread::sleep_for(sleep_time); in rt_sleep()
/oneTBB/examples/graph/dining_philosophers/
H A Ddining_philosophers.cpp219 std::this_thread::sleep_for(eat_time); in eat()
231 std::this_thread::sleep_for(think_time); in think()
/oneTBB/test/conformance/
H A Dconformance_graph.cpp297 std::this_thread::sleep_for(std::chrono::milliseconds(1)); in __anon8ef3c1da0202()
306 std::this_thread::sleep_for(std::chrono::milliseconds(1)); in __anon8ef3c1da0302()
H A Dconformance_enumerable_thread_specific.cpp1182 std::this_thread::yield(); in TestETSIteratorComparisons()
H A Dconformance_concurrent_hash_map.cpp841 std::this_thread::sleep_for(std::chrono::milliseconds(10)); // let it enter the erase in operator ()()
/oneTBB/include/oneapi/tbb/detail/
H A D_machine.h75 using std::this_thread::yield;
/oneTBB/examples/test_all/fibonacci/
H A Dfibonacci.cpp119 using std::this_thread::yield;
/oneTBB/include/oneapi/tbb/
H A Denumerable_thread_specific.h73 return std::this_thread::get_id(); in current_key()
83 auto id = std::this_thread::get_id();
/oneTBB/test/tbbmalloc/
H A Dtest_malloc_whitebox.cpp327 std::this_thread::yield(); in operator ()()