Disruptor-cpp/Disruptor.TestTools/ResetEvent.h at master · githubCode3a/Disruptor-cpp · GitHub

40 lines (28 loc) · 801 Bytes

#pragma once

#include <mutex>

#include <condition_variable>

#include "Disruptor/ClockConfig.h"

namespace Disruptor

{

namespace Tests

{

class ResetEvent

{

public:

explicit ResetEvent(bool signaled = false);

virtual ~ResetEvent() = default;

ResetEvent(const ResetEvent&) = delete;

protected:

virtual bool isSet() const;

virtual void set(bool ensureWaitIsTriggered = false);

virtual void reset();

virtual bool wait(ClockConfig::Duration timeDuration);

private:

bool internalWait(ClockConfig::Duration timeDuration);

bool m_signaled;

mutable std::mutex m_mutex;

std::condition_variable m_conditionVariable;

int m_waitCount;

};

} // namespace Tests

} // namespace Disruptor

Expand file tree