AutoResetEvent.hpp

//
//  Copyright PHOENIX CONTACT Electronics GmbH
//
#pragma once
#include "Arp/System/Core/Arp.h"
#include "Arp/System/Commons/Threading/LockGuard.hpp"
 
namespace Arp { namespace System { namespace Commons { namespace Threading
{
 
// Forward declaration
class ConditionVariable;
 
class AutoResetEvent
{
public: // typedefs
    typedef std::shared_ptr<AutoResetEvent> Ptr;
 
public:
    explicit AutoResetEvent(bool initial = false);
 
    ~AutoResetEvent();
 
    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;
    Mutex syncRoot;
    std::unique_ptr<ConditionVariable> pSignal;
};
 
// inline methods of class AutoResetEvent
inline void AutoResetEvent::Reset()
{
    LockGuard lock(this->syncRoot);
    this->flag = false;
}
 
}}}} // end of namespace Arp::System::Commons::Threading