Method waitFor

Disruptor/YieldingWaitStrategy.cpp:13–27

{

    std::int64_t YieldingWaitStrategy::waitFor(std::int64_t sequence,
                                               Sequence& /*cursor*/,
                                               ISequence& dependentSequence,
                                               ISequenceBarrier& barrier)
    {
        std::int64_t availableSequence;
        auto counter = m_spinTries;

        while ((availableSequence = dependentSequence.value()) < sequence)
        {
            counter = applyWaitMethod(barrier, counter);
        }

        return availableSequence;
    }

    void YieldingWaitStrategy::signalAllWhenBlocking()
    {