AutoResetEvent.hpp

 
//
//  Copyright Phoenix Contact GmbH & Co. KG
//
#pragma once
#include "Arp/System/Core/Arp.h"
 
#include <boost/thread/locks.hpp>
#include <boost/interprocess/sync/interprocess_mutex.hpp>
#include <boost/interprocess/sync/interprocess_condition.hpp>
 
#include <mutex>
#include <thread>
#include <memory>
 
 
namespace Arp { namespace System { namespace Commons { namespace Ipc
{
 
class AutoResetEvent
{
public: // typedefs
    typedef std::shared_ptr<AutoResetEvent> Ptr;
 
public:
    explicit AutoResetEvent(bool initial = false);
    void Set(void);
    void Reset(void);
    bool WaitOne(unsigned long timeoutMs = 0);
 
private: // methods.
    bool WaitOneInfinite(void);
    bool TimedWaitOne(unsigned long timeoutMs);
 
private: // deleted methods
    AutoResetEvent(const AutoResetEvent&) = delete;
    AutoResetEvent& operator=(const AutoResetEvent&) = delete;
 
private: // fields.
    bool flag;
    boost::interprocess::interprocess_mutex syncRoot;
    boost::interprocess::interprocess_condition signal;
};
 
}}}} // end of namespace Arp::System::Commons::Threading