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 <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