Lines Matching refs:std
72 static std::size_t execute_counter() { return my_execute_counter; } in execute_counter()
73 static std::size_t cancel_counter() { return my_cancel_counter; } in cancel_counter()
79 static std::atomic<std::size_t> my_execute_counter;
80 static std::atomic<std::size_t> my_cancel_counter;
89 std::atomic<std::size_t> CountingTask<Body>::my_execute_counter(0);
92 std::atomic<std::size_t> CountingTask<Body>::my_cancel_counter(0);
103 constexpr std::size_t iter_counter = 1000; in test_cancellation_on_exception()
104 for (std::size_t i = 0; i < iter_counter; ++i) { in test_cancellation_on_exception()
146 constexpr std::size_t iter_counter = 10000;
147 for (std::size_t i = 0; i < iter_counter; ++i) {
169 std::uint32_t threads_num = static_cast<std::uint32_t>(utils::get_platform_max_threads());
180 …std::vector<task_type, tbb::cache_aligned_allocator<task_type>> vector_test_task(threads_num, task…
182 constexpr std::size_t iter_counter = 100;
183 for (std::size_t i = 0; i < iter_counter; ++i) {
184 for (std::size_t j = 0; j < threads_num; ++j) {
199 std::uint32_t task_threads_num = static_cast<std::uint32_t>(utils::get_platform_max_threads());
206 std::size_t pfor_iter_count = 10000;
207 std::atomic<std::size_t> pfor_counter(0);
210 tbb::parallel_for(tbb::blocked_range<std::size_t>(0, pfor_iter_count), in __anon509d20bd0502()
211 [&pfor_counter] (tbb::blocked_range<std::size_t>& range) { in __anon509d20bd0502()
222 …std::vector<task_type, tbb::cache_aligned_allocator<task_type>> vector_test_task(task_threads_num,…
224 constexpr std::size_t iter_count = 10;
225 constexpr std::size_t pfor_threads_num = 4;
226 for (std::size_t i = 0; i < iter_count; ++i) {
227 std::vector<std::thread> pfor_threads;
229 for (std::size_t j = 0; j < task_threads_num; ++j) {
233 for (std::size_t k = 0; k < pfor_threads_num; ++k) {
257 std::uint32_t threads_num = static_cast<std::uint32_t>(utils::get_platform_max_threads());
267 …std::vector<task_type, tbb::cache_aligned_allocator<task_type>> vector_test_task(threads_num, task…
269 auto thread_func = [&vector_test_task, &test_context] ( std::size_t idx ) { in __anon509d20bd0802()
273 constexpr std::size_t iter_count = 10;
274 for (std::size_t i = 0; i < iter_count; ++i) {
275 std::vector<std::thread> threads;
277 for (std::size_t k = 0; k < threads_num - 1; ++k) {
303 using task_pool_type = std::vector<SpawningTask, tbb::cache_aligned_allocator<SpawningTask>>;
309 std::size_t delta = 7; in operator ()()
310 std::size_t start_idx = my_current_task.fetch_add(delta); in operator ()()
313 …for (std::size_t idx = start_idx; idx != std::min(my_task_pool.size(), start_idx + delta); ++idx) { in operator ()()
321 static std::atomic<std::size_t> my_current_task;
324 std::atomic<std::size_t> SpawningTaskBody::my_current_task(0);
328 std::uint32_t task_number = 500 * static_cast<std::uint32_t>(utils::get_platform_max_threads());
336 for (std::size_t i = 0; i < task_number; ++i) {
355 tbb::parallel_for(tbb::blocked_range<std::size_t>(0, 100000), in execute()
356 [] (const tbb::blocked_range<std::size_t>& range) { in execute()
358 std::atomic<int> sum{}; in execute()
382 std::atomic<int> suspend_flag{};
385 std::atomic<int> suspend_count{};
386 std::atomic<int> resume_count{};
388 tbb::parallel_for(tbb::blocked_range<std::size_t>(0, 100000),
389 …[&suspend_flag, &test_context, &suspend_count, &resume_count] (const tbb::blocked_range<std::size_… in __anon509d20bd0b02()
396 std::vector<suspended_task, tbb::cache_aligned_allocator<suspended_task>> test_task; in __anon509d20bd0b02()
400 auto thread_id = std::this_thread::get_id(); in __anon509d20bd0b02()
402 CHECK(thread_id == std::this_thread::get_id()); in __anon509d20bd0b02()
418 using task_pool_type = std::vector<bypass_task, tbb::cache_aligned_allocator<bypass_task>>;
421 std::atomic<int>& resume_flag, tbb::task::suspend_point& suspend_tag) in bypass_task()
433 std::size_t ticket = my_current_task++; in execute()
457 std::atomic<int>& my_resume_flag;
459 static std::atomic<int> my_current_task;
462 std::atomic<int> bypass_task::my_current_task(0);
468 std::uint32_t task_number = 500 * static_cast<std::uint32_t>(utils::get_platform_max_threads());
474 std::atomic<int> resume_flag{0};
477 std::vector<bypass_task, tbb::cache_aligned_allocator<bypass_task>> test_task_pool;
479 for (std::size_t i = 0; i < task_number; ++i) {
483 for (std::size_t i = 0; i < utils::get_platform_max_threads(); ++i) {
484 std::size_t ticket = bypass_task::my_current_task++;
491 auto thread_id = std::this_thread::get_id(); in __anon509d20bd0e02()
493 CHECK(thread_id == std::this_thread::get_id()); in __anon509d20bd0e02()
508 std::uint32_t task_number = 500 * static_cast<std::uint32_t>(utils::get_platform_max_threads());
514 int num_threads_in_test_arena = std::max(2, int(utils::get_platform_max_threads()));
520 std::atomic<bool> resume_flag{}, resumed{};
534 std::vector<task_type, tbb::cache_aligned_allocator<task_type>> test_tasks;
536 for (std::size_t i = 0; i < task_number; ++i) {
541 for (std::size_t i = 0; i < task_number / 2; ++i) {
546 auto thread_id = std::this_thread::get_id(); in __anon509d20bd1102()
548 CHECK(thread_id == std::this_thread::get_id()); in __anon509d20bd1102()
550 resume_flag.store(true, std::memory_order_release); in __anon509d20bd1102()
563 tbb::parallel_for(tbb::blocked_range<std::size_t>(task_number / 2, task_number), in __anon509d20bd1302()
564 … [&test_tasks, &test_arena, &test_context] (tbb::blocked_range<std::size_t>& range) { in __anon509d20bd1302()
565 for (std::size_t i = range.begin(); i != range.end(); ++i) { in __anon509d20bd1302()
581 std::uint32_t task_number = static_cast<std::uint32_t>(utils::get_platform_max_threads());
591 …tbb::parallel_for(tbb::blocked_range<std::size_t>(0, 1000), [] (tbb::blocked_range<std::size_t>&) { in __anon509d20bd1702()
597 std::size_t iter_counter = 20;
599 std::vector<task_type, tbb::cache_aligned_allocator<task_type>> test_tasks;
601 for (std::size_t j = 0; j < task_number; ++j) {
606 for (std::size_t i = 0; i < iter_counter; ++i) { in __anon509d20bd1902()
608 for (std::size_t j = 0; j < task_number; ++j) { in __anon509d20bd1902()
612 for (std::size_t j = 0; j < task_number / 2; ++j) { in __anon509d20bd1902()
616 for (std::size_t j = task_number / 2; j < task_number; ++j) { in __anon509d20bd1902()
633 std::uint32_t thread_number = static_cast<std::uint32_t>(utils::get_platform_max_threads());
641 auto thread_id = std::this_thread::get_id(); in __anon509d20bd1a02()
643 CHECK(thread_id == std::this_thread::get_id()); in __anon509d20bd1a02()
649 for (std::size_t i = 0; i < thread_number - 1; ++i) {
666 std::uint32_t task_number = 500 * static_cast<std::uint32_t>(utils::get_platform_max_threads());
671 tbb::task_arena test_arena{int(std::thread::hardware_concurrency() + 1)};
679 std::atomic<bool> end_flag{false};
681 end_flag.store(true, std::memory_order_relaxed); in __anon509d20bd1d02()
685 std::vector<task_type, tbb::cache_aligned_allocator<task_type>> test_tasks;
687 for (std::size_t j = 0; j < task_number; ++j) {
700 constexpr std::size_t iter_count = 10;
701 for (std::size_t k = 0; k < iter_count; ++k) {
705 while (!end_flag.load(std::memory_order_relaxed)) ;
708 end_flag.store(false, std::memory_order_relaxed);
711 for (std::size_t j = 0; j < task_number; ++j) { in __anon509d20bd1f02()
729 std::atomic<int> counter{100000};
751 std::uint32_t thread_number = static_cast<std::uint32_t>(utils::get_platform_max_threads());
759 std::uint32_t critical_task_counter = 1000 * thread_number;
760 std::atomic<std::size_t> task_counter{0};
780 std::this_thread::sleep_for(std::chrono::milliseconds(1)); in __anon509d20bd2102()
789 tbb::parallel_for(std::uint32_t(0), thread_number + 1, [&] (std::uint32_t) { in __anon509d20bd2302()
795 std::vector<std::thread> high_priority_threads;
796 for (std::size_t i = 0; i < thread_number - 1; ++i) {
804 std::this_thread::sleep_for(std::chrono::milliseconds(1));
809 for (std::size_t i = 0; i < thread_number - 1; ++i) {
825 tbb::detail::d0::raii_guard<decltype(func)> guard2(std::move(guard1));
836 …tbb::parallel_for(0, 100, [] (int) { std::this_thread::sleep_for(std::chrono::nanoseconds(10)); }); in __anon509d20bd2602()
838 std::this_thread::sleep_for(std::chrono::microseconds(1));
840 tbb::finalize(handle, std::nothrow_t{});