thread.h

Go to the documentation of this file.

// Copyright (c) 2012, the Dart project authors.  Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.
 
#ifndef RUNTIME_BIN_THREAD_H_
#define RUNTIME_BIN_THREAD_H_
 
#include "platform/globals.h"
 
namespace dart {
namespace bin {
class Thread;
class Mutex;
class Monitor;
}  // namespace bin
}  // namespace dart
 
// Declare the OS-specific types ahead of defining the generic classes.
#if defined(DART_USE_ABSL)
#include "bin/thread_absl.h"
#elif defined(DART_HOST_OS_FUCHSIA)
#include "bin/thread_fuchsia.h"
#elif defined(DART_HOST_OS_LINUX) || defined(DART_HOST_OS_ANDROID)
#include "bin/thread_linux.h"
#elif defined(DART_HOST_OS_MACOS)
#include "bin/thread_macos.h"
#elif defined(DART_HOST_OS_WINDOWS)
#include "bin/thread_win.h"
#else
#error Unknown target os.
#endif
 
namespace dart {
namespace bin {
 
class Thread {
 public:
  static const ThreadId kInvalidThreadId;
 
  typedef void (*ThreadStartFunction)(uword parameter);
 
  // Start a thread running the specified function. Returns 0 if the
  // thread started successfully and a system specific error code if
  // the thread failed to start.
  static int Start(const char* name,
                   ThreadStartFunction function,
                   uword parameters);
 
  static intptr_t GetMaxStackSize();
  static ThreadId GetCurrentThreadId();
  static bool Compare(ThreadId a, ThreadId b);
 
  static void InitOnce();
 
 private:
  DISALLOW_ALLOCATION();
  DISALLOW_IMPLICIT_CONSTRUCTORS(Thread);
};
 
class Mutex {
 public:
  Mutex();
  ~Mutex();
 
  void Lock();
  bool TryLock();
  void Unlock();
 
 private:
  MutexData data_;
 
  DISALLOW_COPY_AND_ASSIGN(Mutex);
};
 
class Monitor {
 public:
  enum WaitResult { kNotified, kTimedOut };
 
  static constexpr int64_t kNoTimeout = 0;
 
  Monitor();
  ~Monitor();
 
  void Enter();
  void Exit();
 
  // Wait for notification or timeout.
  WaitResult Wait(int64_t millis);
  WaitResult WaitMicros(int64_t micros);
 
  // Notify waiting threads.
  void Notify();
  void NotifyAll();
 
 private:
  MonitorData data_;  // OS-specific data.
 
  DISALLOW_COPY_AND_ASSIGN(Monitor);
};
 
}  // namespace bin
}  // namespace dart
 
#endif  // RUNTIME_BIN_THREAD_H_