dart::ThreadBarrier Class Reference

#include <thread_barrier.h>

Public Member Functions
	ThreadBarrier (intptr_t num_threads, intptr_t initial=0)
bool	TryEnter ()
void	Sync ()
void	Release ()

Detailed Description

Definition at line 47 of file thread_barrier.h.

Constructor & Destructor Documentation

ThreadBarrier()

dart::ThreadBarrier::ThreadBarrier ( intptr_t  num_threads, intptr_t  initial = 0  )

inlineexplicit

Definition at line 49 of file thread_barrier.h.

      : ref_count_(num_threads),
        monitor_(),
        participating_(initial),
        remaining_(initial),
        generation_(0) {}

Member Function Documentation

Release()

void dart::ThreadBarrier::Release ( )

inline

Definition at line 83 of file thread_barrier.h.

                 {
    intptr_t old = ref_count_.fetch_sub(1, std::memory_order_acq_rel);
    ASSERT(old > 0);
    if (old == 1) {
      delete this;
    }
  }

Sync()

void dart::ThreadBarrier::Sync ( )

inline

Definition at line 66 of file thread_barrier.h.

              {
    MonitorLocker ml(&monitor_);
    const intptr_t g = generation_;
    remaining_--;
    if (remaining_ == 0) {
      // I'm last, advance to the next generation and wake the others.
      generation_++;
      remaining_ = participating_;
      ml.NotifyAll();
    } else {
      // Waiting for others.
      while (g == generation_) {
        ml.Wait();
      }
    }
  }

TryEnter()

bool dart::ThreadBarrier::TryEnter ( )

inline

Definition at line 56 of file thread_barrier.h.

                  {
    MonitorLocker ml(&monitor_);
    if (generation_ != 0) {
      return false;
    }
    remaining_++;
    participating_++;
    return true;
  }

---

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

• third_party/dart-lang/sdk/runtime/vm/thread_barrier.h