src/hotspot/share/gc/shenandoah/shenandoahRootProcessor.cpp

rev 54044 : Parallelize jni weak ref

*** 32,42 ****
  #include "gc/shenandoah/shenandoahPhaseTimings.hpp"
  #include "gc/shenandoah/shenandoahStringDedup.hpp"
  #include "gc/shenandoah/shenandoahTimingTracker.hpp"
  #include "gc/shenandoah/shenandoahUtils.hpp"
  #include "gc/shenandoah/shenandoahVMOperations.hpp"
! #include "gc/shared/weakProcessor.hpp"
  #include "memory/allocation.inline.hpp"
  #include "memory/iterator.hpp"
  #include "memory/resourceArea.hpp"
  #include "runtime/thread.hpp"
  #include "services/management.hpp"
--- 32,42 ----
  #include "gc/shenandoah/shenandoahPhaseTimings.hpp"
  #include "gc/shenandoah/shenandoahStringDedup.hpp"
  #include "gc/shenandoah/shenandoahTimingTracker.hpp"
  #include "gc/shenandoah/shenandoahUtils.hpp"
  #include "gc/shenandoah/shenandoahVMOperations.hpp"
! #include "gc/shared/weakProcessor.inline.hpp"
  #include "memory/allocation.inline.hpp"
  #include "memory/iterator.hpp"
  #include "memory/resourceArea.hpp"
  #include "runtime/thread.hpp"
  #include "services/management.hpp"
*** 45,55 ****
                                                   ShenandoahPhaseTimings::Phase phase) :
    _process_strong_tasks(new SubTasksDone(SHENANDOAH_RP_PS_NumElements)),
    _srs(n_workers),
    _par_state_string(StringTable::weak_storage()),
    _phase(phase),
!   _coderoots_all_iterator(ShenandoahCodeRoots::iterator())
  {
    heap->phase_timings()->record_workers_start(_phase);
  
    if (ShenandoahStringDedup::is_enabled()) {
      StringDedup::gc_prologue(false);
--- 45,56 ----
                                                   ShenandoahPhaseTimings::Phase phase) :
    _process_strong_tasks(new SubTasksDone(SHENANDOAH_RP_PS_NumElements)),
    _srs(n_workers),
    _par_state_string(StringTable::weak_storage()),
    _phase(phase),
!   _coderoots_all_iterator(ShenandoahCodeRoots::iterator()),
!   _weak_processor_task(n_workers)
  {
    heap->phase_timings()->record_workers_start(_phase);
  
    if (ShenandoahStringDedup::is_enabled()) {
      StringDedup::gc_prologue(false);
*** 190,203 ****
    if (_process_strong_tasks->try_claim_task(SHENANDOAH_RP_PS_SystemDictionary_oops_do)) {
      ShenandoahWorkerTimingsTracker timer(worker_times, ShenandoahPhaseTimings::SystemDictionaryRoots, worker_id);
      SystemDictionary::oops_do(strong_roots);
    }
    if (jni_weak_roots != NULL) {
-     if (_process_strong_tasks->try_claim_task(SHENANDOAH_RP_PS_JNIHandles_weak_oops_do)) {
        ShenandoahWorkerTimingsTracker timer(worker_times, ShenandoahPhaseTimings::JNIWeakRoots, worker_id);
!       WeakProcessor::oops_do(jni_weak_roots);
!     }
    }
  
    if (ShenandoahStringDedup::is_enabled() && weak_roots != NULL) {
      ShenandoahStringDedup::parallel_oops_do(weak_roots, worker_id);
    }
--- 191,203 ----
    if (_process_strong_tasks->try_claim_task(SHENANDOAH_RP_PS_SystemDictionary_oops_do)) {
      ShenandoahWorkerTimingsTracker timer(worker_times, ShenandoahPhaseTimings::SystemDictionaryRoots, worker_id);
      SystemDictionary::oops_do(strong_roots);
    }
    if (jni_weak_roots != NULL) {
        ShenandoahWorkerTimingsTracker timer(worker_times, ShenandoahPhaseTimings::JNIWeakRoots, worker_id);
!       AlwaysTrueClosure always_true;
!       _weak_processor_task.work<AlwaysTrueClosure, OopClosure>(worker_id, &always_true, jni_weak_roots);
    }
  
    if (ShenandoahStringDedup::is_enabled() && weak_roots != NULL) {
      ShenandoahStringDedup::parallel_oops_do(weak_roots, worker_id);
    }