pop_mpsc()

template<typename T , typename StoragePolicy , typename ConcurrencyPolicy = SingleThreadedPolicy, typename AccessPattern = QueueAccess>

std::optional< T > MayaFlux::Memory::RingBuffer< T, StoragePolicy, ConcurrencyPolicy, AccessPattern >::pop_mpsc ( )

inlineprivatenoexcept

Definition at line 1217 of file RingBuffer.hpp.

    {
        const size_t cap = m_storage.capacity();
        const size_t slot = m_state.read_index.load(std::memory_order_relaxed);
 
        if (!m_state.ready_flags[slot].load(std::memory_order_acquire))
            return std::nullopt;
 
        T value = m_storage.buffer[slot];
 
        m_state.ready_flags[slot].store(false, std::memory_order_release);
        m_state.read_index.store(State::increment(slot, cap), std::memory_order_release);
 
        return value;
    }

References MayaFlux::Memory::RingBuffer< T, StoragePolicy, ConcurrencyPolicy, AccessPattern >::m_state, MayaFlux::Memory::RingBuffer< T, StoragePolicy, ConcurrencyPolicy, AccessPattern >::m_storage, and value.

Referenced by MayaFlux::Memory::RingBuffer< T, StoragePolicy, ConcurrencyPolicy, AccessPattern >::pop().

Here is the caller graph for this function: