dart::ConcurrentSweeperTask Class Reference

Inheritance diagram for dart::ConcurrentSweeperTask:

Public Member Functions
	ConcurrentSweeperTask (IsolateGroup *isolate_group)
virtual void	Run ()
Public Member Functions inherited from dart::ThreadPool::Task
virtual	~Task ()
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 165 of file sweeper.cc.

Constructor & Destructor Documentation

ConcurrentSweeperTask()

dart::ConcurrentSweeperTask::ConcurrentSweeperTask ( IsolateGroup *  isolate_group )

inlineexplicit

Definition at line 167 of file sweeper.cc.

      : isolate_group_(isolate_group) {
    ASSERT(isolate_group != nullptr);
    PageSpace* old_space = isolate_group->heap()->old_space();
    MonitorLocker ml(old_space->tasks_lock());
    old_space->set_tasks(old_space->tasks() + 1);
    old_space->set_phase(PageSpace::kSweepingLarge);
  }

Member Function Documentation

Run()

virtual void dart::ConcurrentSweeperTask::Run ( )

inlinevirtual

Implements dart::ThreadPool::Task.

Definition at line 176 of file sweeper.cc.

                     {
    bool result = Thread::EnterIsolateGroupAsNonMutator(isolate_group_,
                                                        Thread::kSweeperTask);
    ASSERT(result);
    PageSpace* old_space = isolate_group_->heap()->old_space();
    {
      Thread* thread = Thread::Current();
      ASSERT(thread->BypassSafepoints());  // Or we should be checking in.
      TIMELINE_FUNCTION_GC_DURATION(thread, "ConcurrentSweep");
 
      old_space->SweepLarge();
 
      {
        MonitorLocker ml(old_space->tasks_lock());
        ASSERT(old_space->phase() == PageSpace::kSweepingLarge);
        old_space->set_phase(PageSpace::kSweepingRegular);
        ml.NotifyAll();
      }
 
      old_space->Sweep(/*exclusive*/ false);
    }
    // Exit isolate cleanly *before* notifying it, to avoid shutdown race.
    Thread::ExitIsolateGroupAsNonMutator();
    // This sweeper task is done. Notify the original isolate.
    {
      MonitorLocker ml(old_space->tasks_lock());
      old_space->set_tasks(old_space->tasks() - 1);
      ASSERT(old_space->phase() == PageSpace::kSweepingRegular);
      old_space->set_phase(PageSpace::kDone);
      ml.NotifyAll();
    }
  }

---

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

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