thread.h

Go to the documentation of this file.

#pragma once

#include <opc/common/interface.h>
#include <opc/common/class_pointers.h>

#include <thread>
#include <functional>
#include <stdexcept>

namespace Common
{

class ThreadObserver : private Common::Interface
{
public:
  virtual void OnSuccess() = 0;
  virtual void OnError(const std::exception & exc) = 0;
};

typedef std::function<void()> ThreadProc;

class Thread
{
public:
  DEFINE_CLASS_POINTERS(Thread)

public:
  Thread(std::function<void()> f, ThreadObserver * observer = 0);

  static Thread::UniquePtr Create(ThreadProc f, ThreadObserver * observer = 0)
  {
    return Thread::UniquePtr(new Thread(f, observer));
  }

  static Thread::UniquePtr Create(void (*f)(), ThreadObserver * observer = 0)
  {
    Common::ThreadProc proc(f);
    return Thread::UniquePtr(new Common::Thread(proc, observer));
  }

  ~Thread();
  void Join();

public:
  void Run();
  static void ThreadProc(Thread * thread);

private:
  ThreadObserver * Observer;
  Common::ThreadProc Func;
  std::thread Impl;
};

} // namespace Common