Searched refs:threads_number (Results 1 – 3 of 3) sorted by relevance
49 std::size_t threads_number = utils::get_platform_max_threads(); variable54 utils::SpinBarrier barrier(threads_number);58 tbb::task_arena arena(static_cast<int>(threads_number - 1), 0);73 for (std::size_t i = 0; i < threads_number - 1; ++i) {
401 void TestConcurrentOperationsWithUnSafeOperations(std::size_t threads_number) { in TestConcurrentOperationsWithUnSafeOperations() argument420 std::unique_ptr<std::atomic<int>[]> active_threads{ new std::atomic<int>[threads_number]() }; in TestConcurrentOperationsWithUnSafeOperations()425 auto all_done = [&active_threads, threads_number] { in TestConcurrentOperationsWithUnSafeOperations()426 for (std::size_t i = 0; i < threads_number; ++i) { in TestConcurrentOperationsWithUnSafeOperations()433 std::unique_ptr<std::atomic<int>[]> ready_threads{ new std::atomic<int>[threads_number]() }; in TestConcurrentOperationsWithUnSafeOperations()434 auto all_ready_leave = [&ready_threads, threads_number] { in TestConcurrentOperationsWithUnSafeOperations()435 for (std::size_t i = 0; i < threads_number; ++i) { in TestConcurrentOperationsWithUnSafeOperations()441 utils::SpinBarrier barrier(threads_number); in TestConcurrentOperationsWithUnSafeOperations()516 utils::NativeParallelFor(threads_number, concurrent_func); in TestConcurrentOperationsWithUnSafeOperations()
56 constraints& set_max_threads_per_core(int threads_number) { in set_max_threads_per_core()57 max_threads_per_core = threads_number; in set_max_threads_per_core()