push_mpsc()

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

bool MayaFlux::Memory::RingBuffer< T, StoragePolicy, ConcurrencyPolicy, AccessPattern >::push_mpsc ( const T &  value )

inlineprivatenoexcept

Definition at line 1202 of file RingBuffer.hpp.

    {
        const size_t cap = m_storage.capacity();
 
        size_t slot = m_state.claim_index.fetch_add(1, std::memory_order_relaxed) & (cap - 1);
 
        if (m_state.ready_flags[slot].load(std::memory_order_acquire))
            return false;
 
        m_storage.buffer[slot] = value;
        m_state.ready_flags[slot].store(true, std::memory_order_release);
 
        return true;
    }

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 >::push().

Here is the caller graph for this function: