Lines Matching refs:workers
833 FlexibleWorkGang* workers = gch->workers();
834 assert(workers != NULL, "Need parallel worker threads.");
835 _state_set.reset(workers->active_workers(), _generation.promotion_failed());
838 workers->run_task(&rp_task);
846 FlexibleWorkGang* workers = gch->workers();
847 assert(workers != NULL, "Need parallel worker threads.");
849 workers->run_task(&enq_task);
931 FlexibleWorkGang* workers = gch->workers();
932 assert(workers != NULL, "Need workgang for parallel work");
934 AdaptiveSizePolicy::calc_active_workers(workers->total_workers(),
935 workers->active_workers(),
937 workers->set_active_workers(active_workers);
978 assert(workers != NULL, "Need parallel worker threads.");
984 // Always set the terminator for the active number of workers
985 // because only those workers go through the termination protocol.
987 ParScanThreadStateSet thread_state_set(workers->active_workers(),
1000 workers->run_task(&tsk);