Lines Matching refs:workers
81 // The number of GC workers is passed to heap_region_par_iterate_chunked().
1215 _g1->workers()->active_workers(),
1451 AdaptiveSizePolicy::calc_active_workers(workers()->total_workers(),
1452 workers()->active_workers(),
1455 n_workers == workers()->total_workers(),
1456 "If not dynamic should be using all the workers");
1457 workers()->set_active_workers(n_workers);
1469 workers()->active_workers() == workers()->total_workers(),
1470 "Unless dynamic should use total workers");
1471 // Use the most recent number of active workers
1472 assert(workers()->active_workers() > 0,
1473 "Active workers not properly set");
1474 set_par_threads(workers()->active_workers());
1475 workers()->run_task(&rebuild_rs_task);
2748 no_of_par_workers == workers()->total_workers(),
2749 "Non dynamic should use fixed number of workers");
2750 // try to spread out the starting points of the workers
2963 uint active_workers = workers()->active_workers();
2965 active_workers == workers()->total_workers(),
2966 "Unless dynamic should use total workers");
2973 // Previous workers starting region is valid
3000 no_of_par_workers == workers()->total_workers(),
3001 "Non dynamic should use fixed number of workers");
3359 _g1h->workers()->active_workers(),
3425 workers()->active_workers() == workers()->total_workers(),
3426 "If not dynamic should be using all the workers");
3427 int n_workers = workers()->active_workers();
3429 workers()->run_task(&task);
3522 workers()->print_worker_threads_on(st);
3533 workers()->threads_do(tc);
3753 const int n = workers() != NULL ? workers()->total_workers() : 1;
3764 const int n = workers() != NULL ? workers()->total_workers() : 1;
3865 workers()->active_workers() : 1);
4337 workers()->run_task(&rsfp_task);
5293 FlexibleWorkGang* workers,
5298 _workers(workers),
5437 G1ParPreserveCMReferentsTask(G1CollectedHeap* g1h,int workers, RefToScanQueueSet *task_queues) :
5441 _terminator(workers, _queues),
5442 _n_workers(workers)
5550 no_of_gc_workers == workers()->active_workers(),
5551 "Need to reset active GC workers");
5559 workers()->run_task(&keep_cm_referents);
5627 G1STWRefProcTaskExecutor par_task_executor(this, workers(), _task_queues, no_of_gc_workers);
5661 assert(no_of_gc_workers == workers()->active_workers(),
5662 "Need to reset active workers");
5666 G1STWRefProcTaskExecutor par_task_executor(this, workers(), _task_queues, no_of_gc_workers);
5699 AdaptiveSizePolicy::calc_active_workers(workers()->total_workers(),
5700 workers()->active_workers(),
5703 n_workers == workers()->total_workers(),
5704 "If not dynamic should be using all the workers");
5705 workers()->set_active_workers(n_workers);
5731 workers()->active_workers() == workers()->total_workers(),
5732 "If not dynamic should be using all the workers");
5733 workers()->run_task(&g1_par_task);
5998 workers()->run_task(&cleanup_task);
6396 // Don't change the number of workers. Use the value previously set
6399 uint n_workers = workers()->active_workers();
6401 n_workers == workers()->total_workers(),
6402 "Otherwise should be using the total number of workers");
6406 workers()->set_active_workers(n_workers);