event.h

/*****************************************************/
/* lean Concurrent              (c) Tobias Zirr 2011 */
/*****************************************************/

#ifndef LEAN_CONCURRENT_EVENT
#define LEAN_CONCURRENT_EVENT

#include "../lean.h"
#include "../tags/noncopyable.h"
#include <windows.h>

namespace lean
{
namespace concurrent
{

class event : public noncopyable
{
private:
    HANDLE m_event;

public:
    event(bool signaled = false)
        : m_event( ::CreateEventW(NULL, true, signaled, NULL) )
    {
        LEAN_ASSERT(m_event != NULL);
    }
    ~event()
    {
        ::CloseHandle(m_event);
    }

    LEAN_INLINE void wait()
    {
        DWORD result = ::WaitForSingleObject(m_event, INFINITE);
        LEAN_ASSERT(result == WAIT_OBJECT_0);
    }

    LEAN_INLINE void set()
    {
        BOOL result = ::SetEvent(m_event);
        LEAN_ASSERT(result != FALSE);
    }
    LEAN_INLINE void reset()
    {
        BOOL result = ::ResetEvent(m_event);
        LEAN_ASSERT(result != FALSE);
    }

    LEAN_INLINE void signaled(bool signaled)
    {
        if (signaled)
            set();
        else
            reset();
    }

    LEAN_INLINE HANDLE native_handle() const
    {
        return m_event;
    }
};

} // namespace

using concurrent::event;

} // namespace

#endif