dart::ParallelScavengerTask Class Reference

Inheritance diagram for dart::ParallelScavengerTask:

Public Member Functions
	ParallelScavengerTask (IsolateGroup *isolate_group, ThreadBarrier *barrier, ParallelScavengerVisitor *visitor, RelaxedAtomic< uintptr_t > *num_busy)
virtual void	Run ()
void	RunEnteredIsolateGroup ()
Public Member Functions inherited from dart::ThreadPool::Task
virtual	~Task ()
virtual void	Run ()=0
Public Member Functions inherited from dart::IntrusiveDListEntry< Task >
	IntrusiveDListEntry ()
	~IntrusiveDListEntry ()

Additional Inherited Members
Protected Member Functions inherited from dart::ThreadPool::Task
	Task ()

Detailed Description

Definition at line 672 of file scavenger.cc.

Constructor & Destructor Documentation

ParallelScavengerTask()

dart::ParallelScavengerTask::ParallelScavengerTask ( IsolateGroup *  isolate_group, ThreadBarrier *  barrier, ParallelScavengerVisitor *  visitor, RelaxedAtomic< uintptr_t > *  num_busy  )

inline

Definition at line 674 of file scavenger.cc.

      : isolate_group_(isolate_group),
        barrier_(barrier),
        visitor_(visitor),
        num_busy_(num_busy) {}

Member Function Documentation

Run()

virtual void dart::ParallelScavengerTask::Run ( )

inlinevirtual

Implements dart::ThreadPool::Task.

Definition at line 683 of file scavenger.cc.

                     {
    if (!barrier_->TryEnter()) {
      barrier_->Release();
      return;
    }
 
    bool result = Thread::EnterIsolateGroupAsHelper(
        isolate_group_, Thread::kScavengerTask, /*bypass_safepoint=*/true);
    ASSERT(result);
 
    RunEnteredIsolateGroup();
 
    Thread::ExitIsolateGroupAsHelper(/*bypass_safepoint=*/true);
 
    barrier_->Sync();
    barrier_->Release();
  }

RunEnteredIsolateGroup()

void dart::ParallelScavengerTask::RunEnteredIsolateGroup ( )

inline

Definition at line 701 of file scavenger.cc.

                                {
    TIMELINE_FUNCTION_GC_DURATION(Thread::Current(), "ParallelScavenge");
 
    num_busy_->fetch_add(1u);
    visitor_->ProcessRoots();
 
    // Phase 1: Copying.
    bool more_to_scavenge = false;
    do {
      do {
        visitor_->ProcessSurvivors();
      } while (visitor_->WaitForWork(num_busy_));
      // Wait for all scavengers to stop.
      barrier_->Sync();
#if defined(DEBUG)
      ASSERT(num_busy_->load() == 0);
      // Caveat: must not allow any marker to continue past the barrier
      // before we checked num_busy, otherwise one of them might rush
      // ahead and increment it.
      barrier_->Sync();
#endif
      // Check if we have any pending properties with marked keys.
      // Those might have been marked by another marker.
      visitor_->ProcessWeakProperties();
      more_to_scavenge = visitor_->HasWork();
      if (more_to_scavenge) {
        // We have more work to do. Notify others.
        num_busy_->fetch_add(1u);
      }
 
      // Wait for all other scavengers to finish processing their pending
      // weak properties and decide if they need to continue marking.
      // Caveat: we need two barriers here to make this decision in lock step
      // between all scavengers and the main thread.
      barrier_->Sync();
      if (!more_to_scavenge && (num_busy_->load() > 0)) {
        // All scavengers continue to mark as long as any single marker has
        // some work to do.
        num_busy_->fetch_add(1u);
        more_to_scavenge = true;
      }
      barrier_->Sync();
    } while (more_to_scavenge);
 
    ASSERT(!visitor_->HasWork());
 
    // Phase 2: Weak processing, statistics.
    visitor_->ProcessWeak();
  }

---

The documentation for this class was generated from the following file:

• third_party/dart-lang/sdk/runtime/vm/heap/scavenger.cc