dart::ThreadRegistry Class Reference

#include <thread_registry.h>

Public Member Functions
	ThreadRegistry ()
	~ThreadRegistry ()
void	VisitObjectPointers (IsolateGroup *isolate_group_of_interest, ObjectPointerVisitor *visitor, ValidationPolicy validate_frames)
void	ForEachThread (std::function< void(Thread *thread)> callback)
void	ReleaseStoreBuffers ()
void	AcquireMarkingStacks ()
void	ReleaseMarkingStacks ()
void	FlushMarkingStacks ()
intptr_t	active_isolates_count ()
Monitor *	threads_lock () const
void	PrintJSON (JSONStream *stream) const

Friends
class	Thread
class	SafepointHandler

Detailed Description

Definition at line 23 of file thread_registry.h.

Constructor & Destructor Documentation

ThreadRegistry()

dart::ThreadRegistry::ThreadRegistry ( )

inline

Definition at line 25 of file thread_registry.h.

      : threads_lock_(),
        active_list_(nullptr),
        free_list_(nullptr),
        active_isolates_count_(0) {}

~ThreadRegistry()

dart::ThreadRegistry::~ThreadRegistry

(

)

Definition at line 12 of file thread_registry.cc.

                                {
  // Go over the free thread list and delete the thread objects.
  {
    MonitorLocker ml(threads_lock());
    // At this point the active list should be empty.
    ASSERT(active_list_ == nullptr);
 
    // Now delete all the threads in the free list.
    while (free_list_ != nullptr) {
      Thread* thread = free_list_;
      free_list_ = thread->next_;
      delete thread;
    }
  }
}

Member Function Documentation

AcquireMarkingStacks()

void dart::ThreadRegistry::AcquireMarkingStacks

(

)

Definition at line 83 of file thread_registry.cc.

                                          {
  MonitorLocker ml(threads_lock());
  Thread* thread = active_list_;
  while (thread != nullptr) {
    if (!thread->BypassSafepoints()) {
      thread->MarkingStackAcquire();
      thread->DeferredMarkingStackAcquire();
    }
    thread = thread->next_;
  }
}

active_isolates_count()

intptr_t dart::ThreadRegistry::active_isolates_count ( )

inline

Definition at line 43 of file thread_registry.h.

{ return active_isolates_count_.load(); }

FlushMarkingStacks()

void dart::ThreadRegistry::FlushMarkingStacks

(

)

Definition at line 108 of file thread_registry.cc.

                                        {
  MonitorLocker ml(threads_lock());
  Thread* thread = active_list_;
  while (thread != nullptr) {
    if (!thread->BypassSafepoints() && thread->is_marking()) {
      thread->MarkingStackFlush();
      thread->DeferredMarkingStackFlush();
      ASSERT(thread->is_marking());
    }
    thread = thread->next_;
  }
}

ForEachThread()

void dart::ThreadRegistry::ForEachThread

(

std::function< void(Thread *thread)>

callback

)

Definition at line 62 of file thread_registry.cc.

                                                {
  MonitorLocker ml(threads_lock());
  Thread* thread = active_list_;
  while (thread != nullptr) {
    callback(thread);
    thread = thread->next_;
  }
}

PrintJSON()

void dart::ThreadRegistry::PrintJSON

(

JSONStream *

stream

)

const

ReleaseMarkingStacks()

void dart::ThreadRegistry::ReleaseMarkingStacks

(

)

Definition at line 95 of file thread_registry.cc.

                                          {
  MonitorLocker ml(threads_lock());
  Thread* thread = active_list_;
  while (thread != nullptr) {
    if (!thread->BypassSafepoints()) {
      thread->MarkingStackRelease();
      thread->DeferredMarkingStackRelease();
      ASSERT(!thread->is_marking());
    }
    thread = thread->next_;
  }
}

ReleaseStoreBuffers()

void dart::ThreadRegistry::ReleaseStoreBuffers

(

)

Definition at line 72 of file thread_registry.cc.

                                         {
  MonitorLocker ml(threads_lock());
  Thread* thread = active_list_;
  while (thread != nullptr) {
    if (!thread->BypassSafepoints()) {
      thread->ReleaseStoreBuffer();
    }
    thread = thread->next_;
  }
}

threads_lock()

Monitor * dart::ThreadRegistry::threads_lock ( ) const

inline

Definition at line 45 of file thread_registry.h.

{ return &threads_lock_; }

VisitObjectPointers()

void dart::ThreadRegistry::VisitObjectPointers	(	IsolateGroup *	isolate_group_of_interest,
		ObjectPointerVisitor *	visitor,
		ValidationPolicy	validate_frames
	)

Definition at line 44 of file thread_registry.cc.

                                      {
  MonitorLocker ml(threads_lock());
  Thread* thread = active_list_;
  while (thread != nullptr) {
    if (thread->isolate_group() == isolate_group_of_interest) {
      // The mutator thread is visited by the isolate itself (see
      // [IsolateGroup::VisitStackPointers]).
      if (!thread->IsDartMutatorThread()) {
        thread->VisitObjectPointers(visitor, validate_frames);
      }
    }
    thread = thread->next_;
  }
}

Friends And Related Symbol Documentation

SafepointHandler

friend class SafepointHandler

friend

Definition at line 69 of file thread_registry.h.

Thread

friend class Thread

friend

Definition at line 68 of file thread_registry.h.

---

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

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