| /oneTBB/test/tbb/ |
| H A D | test_partitioner.cpp | 67 int thread_id = tbb::this_task_arena::current_thread_index(); in test() local
68 trace[thread_id].emplace_back(r.begin(), r.end()); in test()
85 for (std::size_t thread_id = 0; thread_id < num_threads; ++thread_id) { in test() local
86 auto trace_size = trace[thread_id].size(); in test()
88 auto previous_call_range = trace[thread_id][1]; in test()
91 const auto& current_call_range = trace[thread_id][invocation]; in test()
105 "Thread " << thread_id << " executed extra " << trace_size - repeats in test()
110 "Thread " << thread_id << " executed " << repeats - trace_size in test()
|
| H A D | test_resumable_tasks.cpp | 94 m_asyncActivity(a_), thread_id(id) {} in SuspendBody()
96 CHECK(thread_id == std::this_thread::get_id()); in operator ()()
102 std::thread::id thread_id; member
395 auto thread_id = std::this_thread::get_id(); in TestObservers() local
396 tbb::task::suspend([thread_id](tbb::task::suspend_point tag) { in TestObservers()
397 CHECK(thread_id == std::this_thread::get_id()); in TestObservers()
|
| H A D | test_concurrent_queue_whitebox.cpp | 49 void operator()( const int thread_id ) const { in operator ()()
51 value_type elem = value_type(thread_id); in operator ()()
|
| H A D | test_task.cpp | 400 auto thread_id = std::this_thread::get_id(); in __anon509d20bd0b02() local
401 … tbb::task::suspend([&wait, &test_context, &test_task, thread_id] (tbb::task::suspend_point tag) { in __anon509d20bd0b02()
402 CHECK(thread_id == std::this_thread::get_id()); in __anon509d20bd0b02()
491 auto thread_id = std::this_thread::get_id(); in __anon509d20bd0e02() local
492 … tbb::task::suspend([&resume_flag, &test_suspend_tag, thread_id] (tbb::task::suspend_point tag) { in __anon509d20bd0e02()
493 CHECK(thread_id == std::this_thread::get_id()); in __anon509d20bd0e02()
546 auto thread_id = std::this_thread::get_id(); in __anon509d20bd1102() local
547 … tbb::task::suspend([&resume_flag, &test_suspend_tag, thread_id] (tbb::task::suspend_point tag) { in __anon509d20bd1102()
548 CHECK(thread_id == std::this_thread::get_id()); in __anon509d20bd1102()
641 auto thread_id = std::this_thread::get_id(); in __anon509d20bd1a02() local
[all …]
|
| H A D | test_async_node.cpp | 62 std::thread::id thread_id; member
64 place_wrapper( int v = 0 ) : value(v), thread_id(std::this_thread::get_id()) {} in place_wrapper()
68 : value(v.value), thread_id(v.thread_id) in place_wrapper()
75 thread_id = v.thread_id; in operator =()
91 … CHECK_MESSAGE( ( (a.thread_id != b.thread_id)), "same thread used to execute adjacent nodes"); in check()
|
| H A D | test_concurrent_vector.cpp | 443 &all_ready_leave, &ready_threads] (std::size_t thread_id) in TestConcurrentOperationsWithUnSafeOperations()
446 utils::FastRandom<> rand(thread_id); in TestConcurrentOperationsWithUnSafeOperations()
455 if (all_done()) ready_threads[thread_id] = 1; in TestConcurrentOperationsWithUnSafeOperations()
464 if (active_threads[thread_id] == 1 || local_operations[i] == 0) { in TestConcurrentOperationsWithUnSafeOperations()
488 … if (curr_unsafe_thread.compare_exchange_strong(default_unsafe_thread, int(thread_id))) { in TestConcurrentOperationsWithUnSafeOperations()
512 if (i >= local_operations.size()) active_threads[thread_id] = 1; in TestConcurrentOperationsWithUnSafeOperations()
|
| /oneTBB/examples/parallel_for/tachyon/src/ |
| H A D | trace.tbb.cpp | 203 thread_id_t::reference thread_id = thread_ids.local(); in operator ()() local
204 if (thread_id == -1) in operator ()()
205 thread_id = thread_number++; in operator ()()
207 int pos = thread_id % NUM_COLORS; in operator ()()
|
| /oneTBB/test/common/ |
| H A D | allocator_test_common.h | 253 void operator()(std::size_t thread_id) const { in operator()
259 std::size_t i = static_cast<unsigned char>(PseudoRandomValue(k, thread_id)); in operator()
260 if(!array[i]) check_allocate(array, i, thread_id); in operator()
261 else check_deallocate(array, i, thread_id); in operator()
265 check_deallocate(array, k, thread_id); in operator()
|
| H A D | concurrent_priority_queue_common.h | 257 void operator()( const std::size_t thread_id ) const { in operator()
258 T elem = my_min + T(int(thread_id)); in operator()
304 void operator()( const std::size_t thread_id ) const { in operator()
305 T elem = T(int(thread_id + 1)); in operator()
|
| /oneTBB/test/conformance/ |
| H A D | conformance_combinable.cpp | 433 void operator()(int thread_id ) const { in operator ()()
437 existed = thread_id & 1; in operator ()()
440 REQUIRE_MESSAGE((!existed || (oldval == thread_id)), "Error on fetched value"); in operator ()()
441 existed = thread_id & 1; in operator ()()
442 locals->local(existed) = thread_id; in operator ()()
|
| H A D | conformance_concurrent_queue.cpp | 643 void operator()( std::size_t thread_id ) const { in operator ()()
647 CHECK(thread_id < nthread); in operator ()()
660 g.set_thread_id(thread_id); in operator ()()
672 Sum[thread_id] = sum; in operator ()()
942 void operator()(std::size_t thread_id) const { in operator ()()
943 if (thread_id == max) { in operator ()()
967 void operator()(std::size_t thread_id) const { in operator ()()
969 if (thread_id == std::size_t(max)) { in operator ()()
|
| /oneTBB/src/tbb/ |
| H A D | rml_thread_monitor.h | 142 unsigned thread_id; in launch() local
145 …d(stack_size), thread_routine, arg, STACK_SIZE_PARAM_IS_A_RESERVATION | create_flags, &thread_id ); in launch()
|