Lines Matching refs:workers
377 GCTaskManager::GCTaskManager(uint workers) :
378 _workers(workers),
385 GCTaskManager::GCTaskManager(uint workers, NotifyDoneClosure* ndc) :
386 _workers(workers),
395 tty->print_cr("GCTaskManager::initialize: workers: %u", workers());
397 assert(workers() != 0, "no workers");
406 _resource_flag = NEW_C_HEAP_ARRAY(bool, workers(), mtGC);
409 // Distribute the workers among the available processors,
411 uint* processor_assignment = NEW_C_HEAP_ARRAY(uint, workers(), mtGC);
413 !os::distribute_processes(workers(), processor_assignment)) {
414 for (uint a = 0; a < workers(); a += 1) {
418 _thread = NEW_C_HEAP_ARRAY(GCTaskThread*, workers(), mtGC);
419 for (uint t = 0; t < workers(); t += 1) {
424 for (uint t = 0; t < workers(); t += 1) {
433 for (uint w = 0; w < workers(); w += 1) {
441 for (uint s = 0; s < workers(); s += 1) {
447 assert(busy_workers() == 0, "still have busy workers");
454 for (uint i = 0; i < workers(); i += 1) {
479 AdaptiveSizePolicy::calc_active_workers(workers(),
489 "all_workers_active() %d workers %d "
491 all_workers_active(), workers(), active_workers(),
496 // Create IdleGCTasks for inactive workers.
510 // are the number currently idle. If all the workers are being
518 workers() - active_workers() - idle_workers();
525 gclog_or_tty->print_cr("JT: %d workers %d active %d "
528 workers(),
539 assert(workers() == active_workers() + idle_workers(),
540 "total workers should equal active + inactive");
565 uint num_thr = workers();
574 uint num_thr = workers();
581 assert(which < workers(), "index out of bounds");
587 assert(which < workers(), "index out of bounds");
625 // GC workers wait in get_task() for new work to be added
627 // a notify is sent to the waiting GC workers which then
753 for (uint i = 0; i < workers(); i += 1) {
770 // then the GC workers are notified that there is new work to
776 // and then the GC workers are notified of new work. The tasks are
780 // to complete. GC workers that execute a stealing task remain in
789 // workers once it is added to the list of tasks.
801 assert(which < workers(), "index out of bounds");
806 assert(which < workers(), "index out of bounds");
930 tty->print_cr("BarrierGCTask::do_it(%u) waiting on %u workers",