push()

template<typename T , size_t Capacity>

bool MayaFlux::Memory::PendingQueue< T, Capacity >::push ( T &&  value )

inlinenoexcept

Enqueue an operation from any thread.

Returns

false if the queue is full; the operation is left untouched.

Definition at line 57 of file PendingQueue.hpp.

    {
        size_t pos = m_enqueue.load(std::memory_order_relaxed);
        Cell* cell = nullptr;
 
        for (;;) {
            cell = &m_cells[pos & MASK];
            const size_t seq = cell->sequence.load(std::memory_order_acquire);
            const auto diff = static_cast<std::intptr_t>(seq) - static_cast<std::intptr_t>(pos);
 
            if (diff == 0) {
                if (m_enqueue.compare_exchange_weak(pos, pos + 1, std::memory_order_relaxed)) {
                    break;
                }
            } else if (diff < 0) {
                return false;
            } else {
                pos = m_enqueue.load(std::memory_order_relaxed);
            }
        }
 
        cell->value = std::move(value);
        cell->sequence.store(pos + 1, std::memory_order_release);
        return true;
    }

References MayaFlux::Memory::PendingQueue< T, Capacity >::m_cells, MayaFlux::Memory::PendingQueue< T, Capacity >::m_enqueue, MayaFlux::Memory::PendingQueue< T, Capacity >::MASK, MayaFlux::Memory::PendingQueue< T, Capacity >::Cell::sequence, value, and MayaFlux::Memory::PendingQueue< T, Capacity >::Cell::value.