equal
deleted
inserted
replaced
586 assert(active_tasks <= _max_num_tasks, "we should not have more"); |
586 assert(active_tasks <= _max_num_tasks, "we should not have more"); |
587 |
587 |
588 _num_active_tasks = active_tasks; |
588 _num_active_tasks = active_tasks; |
589 // Need to update the three data structures below according to the |
589 // Need to update the three data structures below according to the |
590 // number of active threads for this phase. |
590 // number of active threads for this phase. |
591 _terminator = TaskTerminator((int) active_tasks, _task_queues); |
591 _terminator.terminator()->reset_for_reuse((int) active_tasks); |
592 _first_overflow_barrier_sync.set_n_workers((int) active_tasks); |
592 _first_overflow_barrier_sync.set_n_workers((int) active_tasks); |
593 _second_overflow_barrier_sync.set_n_workers((int) active_tasks); |
593 _second_overflow_barrier_sync.set_n_workers((int) active_tasks); |
594 } |
594 } |
595 |
595 |
596 void G1ConcurrentMark::set_concurrency_and_phase(uint active_tasks, bool concurrent) { |
596 void G1ConcurrentMark::set_concurrency_and_phase(uint active_tasks, bool concurrent) { |