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