chromiumos-wide-profiling/compat/ext/detail/thread.h

// Copyright 2016 The Chromium OS Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#ifndef CHROMIUMOS_WIDE_PROFILING_COMPAT_EXT_DETAIL_THREAD_H_
#define CHROMIUMOS_WIDE_PROFILING_COMPAT_EXT_DETAIL_THREAD_H_

#include <chrono>
#include <condition_variable>
#include <mutex>
#include <thread>

namespace quipper {

class Thread : public quipper::compat::ThreadInterface {
 public:
  explicit Thread(const string& name_prefix) {}

  void Start() override {
    thread_ = std::thread(&Thread::Run, this);
  }

  void Join() override {
    thread_.join();
  }

  pid_t tid() override {
    return thread_.native_handle();
  }

 protected:
  void Run() override = 0;

 private:
  std::thread thread_;
};

class Notification : public quipper::compat::NotificationInterface {
 public:
  void Wait() override {
    std::unique_lock<std::mutex> lock(mutex_);
    event_.wait(lock);
  }

  bool WaitWithTimeout(int timeout_ms) override {
    std::unique_lock<std::mutex> lock(mutex_);
    return event_.wait_for(lock, std::chrono::milliseconds(timeout_ms)) ==
        std::cv_status::no_timeout;
  }

  void Notify() override {
    event_.notify_all();
  }

 private:
  std::condition_variable event_;
  std::mutex mutex_;
};

}  // namespace quipper

#endif  // CHROMIUMOS_WIDE_PROFILING_COMPAT_EXT_DETAIL_THREAD_H_