thread.cpp

Go to the documentation of this file.

#include <opc/common/thread.h>

#include <iostream>

namespace Common
{

    Thread::Thread(std::function<void()> f, ThreadObserver* observer)
      : Observer(observer)
      , Func(f)
      , Impl(Thread::ThreadProc, this)
    {
    }

    Thread::~Thread()
    {
      try
      {
        Join();
      }
      catch (std::exception&)
      {
      }
    }

    void Thread::Join()
    {
      Impl.join();
    }

    void Thread::Run()
    {
      try
      {
        Func();
        if (Observer)
        {
          Observer->OnSuccess();
        }
      }
      catch (const std::exception& exc)
      {
        if (Observer)
        {
          Observer->OnError(exc);
        }
      }
    }

    void Thread::ThreadProc(Thread* thread)
    {
      thread->Run();
    }

} // namespace Common