dart::ConcurrentForceGrowthScopeTask Class Reference

Inheritance diagram for dart::ConcurrentForceGrowthScopeTask:

Public Member Functions
	ConcurrentForceGrowthScopeTask (IsolateGroup *isolate_group, Monitor *monitor, intptr_t *done_count)
virtual void	Run ()
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 779 of file heap_test.cc.

Constructor & Destructor Documentation

ConcurrentForceGrowthScopeTask()

dart::ConcurrentForceGrowthScopeTask::ConcurrentForceGrowthScopeTask ( IsolateGroup *  isolate_group, Monitor *  monitor, intptr_t *  done_count  )

inline

Definition at line 781 of file heap_test.cc.

      : isolate_group_(isolate_group),
        monitor_(monitor),
        done_count_(done_count) {}

Member Function Documentation

Run()

virtual void dart::ConcurrentForceGrowthScopeTask::Run ( )

inlinevirtual

Implements dart::ThreadPool::Task.

Definition at line 788 of file heap_test.cc.

                     {
    const bool kBypassSafepoint = false;
    Thread::EnterIsolateGroupAsHelper(isolate_group_, Thread::kUnknownTask,
                                      kBypassSafepoint);
    {
      Thread* thread = Thread::Current();
      StackZone stack_zone(thread);
 
      GrowableObjectArray& accumulate =
          GrowableObjectArray::Handle(GrowableObjectArray::New());
      Object& element = Object::Handle();
      for (intptr_t i = 0; i < 1000; i++) {
        // Lots of entering and leaving ForceGrowth scopes. Previously, this
        // would have been data races on the per-Heap force-growth flag.
        {
          ForceGrowthScope force_growth(thread);
          GrowableObjectArrayPtr unsafe_accumulate = accumulate.ptr();
          element = Array::New(0);
          accumulate = unsafe_accumulate;
        }
        accumulate.Add(element);
      }
    }
    Thread::ExitIsolateGroupAsHelper(kBypassSafepoint);
    // Notify the main thread that this thread has exited.
    {
      MonitorLocker ml(monitor_);
      *done_count_ += 1;
      ml.Notify();
    }
  }

---

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

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