Searched refs:active_threads (Results 1 – 2 of 2) sorted by relevance
410 int active_threads = 0; in propagate_chain_reaction() local412 ++active_threads; in propagate_chain_reaction()414 ++active_threads; in propagate_chain_reaction()416 wake_some( 0, active_threads ); in propagate_chain_reaction()975 --active_threads; in wake_some()991 while( active_threads ) { in wake_some()993 --active_threads; in wake_some()1065 int active_threads = 0; in adjust_job_count_estimate() local1067 ++active_threads; in adjust_job_count_estimate()1069 ++active_threads; in adjust_job_count_estimate()[all …]
420 std::unique_ptr<std::atomic<int>[]> active_threads{ new std::atomic<int>[threads_number]() }; in TestConcurrentOperationsWithUnSafeOperations() local425 auto all_done = [&active_threads, threads_number] { in TestConcurrentOperationsWithUnSafeOperations()427 if (active_threads[i].load(std::memory_order_relaxed) == 0) return false; in TestConcurrentOperationsWithUnSafeOperations()442 …concurrent_func = [&operations, &vector, &curr_unsafe_thread, &barrier, &all_done, &active_threads, in TestConcurrentOperationsWithUnSafeOperations()464 if (active_threads[thread_id] == 1 || local_operations[i] == 0) { in TestConcurrentOperationsWithUnSafeOperations()512 if (i >= local_operations.size()) active_threads[thread_id] = 1; in TestConcurrentOperationsWithUnSafeOperations()