dart::MutatorThreadPool Class Reference

#include <isolate.h>

Inheritance diagram for dart::MutatorThreadPool:

Public Member Functions
	MutatorThreadPool (IsolateGroup *isolate_group, intptr_t max_pool_size)
virtual	~MutatorThreadPool ()
Public Member Functions inherited from dart::ThreadPool
	ThreadPool (uintptr_t max_pool_size=0)
virtual	~ThreadPool ()
template<typename T , typename... Args>
bool	Run (Args &&... args)
bool	CurrentThreadIsWorker ()
void	MarkCurrentWorkerAsBlocked ()
void	MarkCurrentWorkerAsUnBlocked ()
void	Shutdown ()
uint64_t	workers_started () const
uint64_t	workers_stopped () const

Protected Member Functions
virtual void	OnEnterIdleLocked (MonitorLocker *ml)
Protected Member Functions inherited from dart::ThreadPool
bool	ShuttingDownLocked ()
bool	TasksWaitingToRunLocked ()

Detailed Description

Definition at line 251 of file isolate.h.

Constructor & Destructor Documentation

MutatorThreadPool()

dart::MutatorThreadPool::MutatorThreadPool ( IsolateGroup *  isolate_group, intptr_t  max_pool_size  )

inline

Definition at line 253 of file isolate.h.

      : ThreadPool(max_pool_size), isolate_group_(isolate_group) {}

~MutatorThreadPool()

virtual dart::MutatorThreadPool::~MutatorThreadPool ( )

inlinevirtual

Definition at line 255 of file isolate.h.

{}

Member Function Documentation

OnEnterIdleLocked()

void dart::MutatorThreadPool::OnEnterIdleLocked ( MonitorLocker *  ml )

protectedvirtual

Reimplemented from dart::ThreadPool.

Definition at line 278 of file isolate.cc.

                                                           {
  if (FLAG_idle_timeout_micros == 0) return;
 
  // If the isolate has not started running application code yet, we ignore the
  // idle time.
  if (!isolate_group_->initial_spawn_successful()) return;
 
  int64_t idle_expiry = 0;
  // Obtain the idle time we should wait.
  if (isolate_group_->idle_time_handler()->ShouldNotifyIdle(&idle_expiry)) {
    MonitorLeaveScope mls(ml);
    NotifyIdle();
    return;
  }
 
  // Avoid shutdown having to wait for the timeout to expire.
  if (ShuttingDownLocked()) return;
 
  // Wait for the recommended idle timeout.
  // We can be woken up because of a), b) or c)
  const auto result =
      ml->WaitMicros(idle_expiry - OS::GetCurrentMonotonicMicros());
 
  // a) If there are new tasks we have to run them.
  if (TasksWaitingToRunLocked()) return;
 
  // b) If the thread pool is shutting down we're done.
  if (ShuttingDownLocked()) return;
 
  // c) We timed out and should run the idle notifier.
  if (result == Monitor::kTimedOut &&
      isolate_group_->idle_time_handler()->ShouldNotifyIdle(&idle_expiry)) {
    MonitorLeaveScope mls(ml);
    NotifyIdle();
    return;
  }
 
  // There must've been another thread doing active work in the meantime.
  // If that thread becomes idle and is the last idle thread it will run this
  // code again.
}

---

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

• third_party/dart-lang/sdk/runtime/vm/isolate.h
• third_party/dart-lang/sdk/runtime/vm/isolate.cc