drain()

template<typename T , size_t Capacity>

template<typename Apply >

size_t MayaFlux::Memory::PendingQueue< T, Capacity >::drain ( Apply &&  apply )

inline

Apply and remove every published operation in claim order.

Parameters

apply

Callable taking T&&.

Returns

Number of operations applied.

Stops at the first cell whose producer has claimed but not yet published; that operation and everything behind it is applied by the next drain. Single consumer only.

Definition at line 93 of file PendingQueue.hpp.

    {
        size_t pos = m_dequeue.load(std::memory_order_relaxed);
        size_t count = 0;
 
        for (;;) {
            Cell& cell = m_cells[pos & MASK];
            if (cell.sequence.load(std::memory_order_acquire) != pos + 1) {
                break;
            }
 
            T value = std::move(cell.value);
            cell.value = T {};
            cell.sequence.store(pos + Capacity, std::memory_order_release);
            ++pos;
            ++count;
            m_dequeue.store(pos, std::memory_order_relaxed);
 
            std::forward<Apply>(apply)(std::move(value));
        }
 
        return count;
    }

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