dart::StressTask Class Reference

Inheritance diagram for dart::StressTask:

Public Types
enum	State { kStart = StateMachineTask::kNext }
Public Types inherited from dart::StateMachineTask
enum	State {   kInitialized = 0 , kEntered , kPleaseExit , kExited ,   kNext }

Public Member Functions
	StressTask (std::shared_ptr< Data > data)
Public Member Functions inherited from dart::StateMachineTask
	StateMachineTask (std::shared_ptr< Data > data)
virtual void	Run ()
Public Member Functions inherited from dart::ThreadPool::Task
virtual	~Task ()
Public Member Functions inherited from dart::IntrusiveDListEntry< Task >
	IntrusiveDListEntry ()
	~IntrusiveDListEntry ()

Protected Member Functions
Data *	data ()
virtual void	RunInternal ()
Protected Member Functions inherited from dart::ThreadPool::Task
	Task ()

Additional Inherited Members
Protected Attributes inherited from dart::StateMachineTask
std::shared_ptr< Data >	data_
Thread *	thread_ = nullptr

Detailed Description

Definition at line 511 of file safepoint_test.cc.

Member Enumeration Documentation

State

enum dart::StressTask::State

Enumerator
kStart

Definition at line 513 of file safepoint_test.cc.

             {
    kStart = StateMachineTask::kNext,
  };

Constructor & Destructor Documentation

StressTask()

dart::StressTask::StressTask ( std::shared_ptr< Data >  data )

inlineexplicit

Definition at line 517 of file safepoint_test.cc.

: StateMachineTask(data) {}

Member Function Documentation

data()

Data * dart::StressTask::data ( )

inlineprotected

Definition at line 520 of file safepoint_test.cc.

{ return reinterpret_cast<Data*>(data_.get()); }

RunInternal()

virtual void dart::StressTask::RunInternal ( )

inlineprotectedvirtual

Implements dart::StateMachineTask.

Definition at line 522 of file safepoint_test.cc.

                             {
    data_->WaitUntil(kStart);
 
    Random random(thread_->isolate_group()->random()->NextUInt64());
    while (!data()->IsIn(kPleaseExit)) {
      const auto us = random.NextUInt32() % 3;
      switch (random.NextUInt32() % 5) {
        case 0: {
          DeoptSafepointOperationScope safepoint_op(thread_);
          OS::SleepMicros(us);
          break;
        }
        case 1: {
          GcSafepointOperationScope safepoint_op(thread_);
          OS::SleepMicros(us);
          break;
        }
        case 2: {
          const bool kBypassSafepoint = false;
          Thread::ExitIsolateGroupAsHelper(kBypassSafepoint);
          OS::SleepMicros(us);
          Thread::EnterIsolateGroupAsHelper(
              data_->isolate_group_, Thread::kUnknownTask, kBypassSafepoint);
          thread_ = Thread::Current();
          break;
        }
        case 3: {
          thread_->EnterSafepoint();
          OS::SleepMicros(us);
          thread_->ExitSafepoint();
          break;
        }
        case 4: {
          if (thread_->IsSafepointRequested()) {
            thread_->BlockForSafepoint();
          }
          break;
        }
      }
    }
  }

---

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

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