src/share/vm/gc/cms/parNewGeneration.cpp

*** 802,812 ****
  
  
  void ParNewRefProcTaskExecutor::execute(ProcessTask& task)
  {
    GenCollectedHeap* gch = GenCollectedHeap::heap();
!   FlexibleWorkGang* workers = gch->workers();
    assert(workers != NULL, "Need parallel worker threads.");
    _state_set.reset(workers->active_workers(), _generation.promotion_failed());
    ParNewRefProcTaskProxy rp_task(task, _generation, *_generation.next_gen(),
                                   _generation.reserved().end(), _state_set);
    workers->run_task(&rp_task);
--- 802,812 ----
  
  
  void ParNewRefProcTaskExecutor::execute(ProcessTask& task)
  {
    GenCollectedHeap* gch = GenCollectedHeap::heap();
!   WorkGang* workers = gch->workers();
    assert(workers != NULL, "Need parallel worker threads.");
    _state_set.reset(workers->active_workers(), _generation.promotion_failed());
    ParNewRefProcTaskProxy rp_task(task, _generation, *_generation.next_gen(),
                                   _generation.reserved().end(), _state_set);
    workers->run_task(&rp_task);
*** 815,825 ****
  }
  
  void ParNewRefProcTaskExecutor::execute(EnqueueTask& task)
  {
    GenCollectedHeap* gch = GenCollectedHeap::heap();
!   FlexibleWorkGang* workers = gch->workers();
    assert(workers != NULL, "Need parallel worker threads.");
    ParNewRefEnqueueTaskProxy enq_task(task);
    workers->run_task(&enq_task);
  }
  
--- 815,825 ----
  }
  
  void ParNewRefProcTaskExecutor::execute(EnqueueTask& task)
  {
    GenCollectedHeap* gch = GenCollectedHeap::heap();
!   WorkGang* workers = gch->workers();
    assert(workers != NULL, "Need parallel worker threads.");
    ParNewRefEnqueueTaskProxy enq_task(task);
    workers->run_task(&enq_task);
  }
  
*** 889,899 ****
    GenCollectedHeap* gch = GenCollectedHeap::heap();
  
    _gc_timer->register_gc_start();
  
    AdaptiveSizePolicy* size_policy = gch->gen_policy()->size_policy();
!   FlexibleWorkGang* workers = gch->workers();
    assert(workers != NULL, "Need workgang for parallel work");
    uint active_workers =
         AdaptiveSizePolicy::calc_active_workers(workers->total_workers(),
                                                 workers->active_workers(),
                                                 Threads::number_of_non_daemon_threads());
--- 889,899 ----
    GenCollectedHeap* gch = GenCollectedHeap::heap();
  
    _gc_timer->register_gc_start();
  
    AdaptiveSizePolicy* size_policy = gch->gen_policy()->size_policy();
!   WorkGang* workers = gch->workers();
    assert(workers != NULL, "Need workgang for parallel work");
    uint active_workers =
         AdaptiveSizePolicy::calc_active_workers(workers->total_workers(),
                                                 workers->active_workers(),
                                                 Threads::number_of_non_daemon_threads());