Lines Matching refs:active_threads
410 int active_threads = 0; in propagate_chain_reaction() local
412 ++active_threads; in propagate_chain_reaction()
414 ++active_threads; in propagate_chain_reaction()
416 wake_some( 0, active_threads ); in propagate_chain_reaction()
428 void wake_some(int additional_slack, int active_threads);
951 void ipc_server::wake_some( int additional_slack, int active_threads ) { in wake_some() argument
957 … while( active_threads>0 && my_asleep_list_root.load(std::memory_order_relaxed) && w<wakee+2 ) { in wake_some()
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() local
1067 ++active_threads; in adjust_job_count_estimate()
1069 ++active_threads; in adjust_job_count_estimate()
1072 wake_some( delta, active_threads ); in adjust_job_count_estimate()