Method internalWait

Disruptor.TestTools/ResetEvent.cpp:36–65

    }

    bool ResetEvent::internalWait(ClockConfig::Duration timeDuration)
    {
        std::unique_lock< decltype(m_mutex) > lock(m_mutex);

        auto hasReceivedSignal = false;

        if (!m_signaled)
        {
            ++m_waitCount;

            if (timeDuration == ClockConfig::Duration())
            {
                do
                {
                    m_conditionVariable.wait(lock);
                }
                while (!m_signaled);

                hasReceivedSignal = true;
            }
            else
            {
                hasReceivedSignal = m_conditionVariable.wait_for(lock, timeDuration, [this] { return this->m_signaled; });
            }

            --m_waitCount;
        }

        return hasReceivedSignal || m_signaled;
    }

    bool ResetEvent::wait(ClockConfig::Duration timeDuration)
    {