MayaFlux 0.2.0
Digital-First Multimedia Processing Framework
Loading...
Searching...
No Matches

◆ pop_lockfree()

template<typename T , typename StoragePolicy , typename ConcurrencyPolicy = SingleThreadedPolicy, typename AccessPattern = QueueAccess>
std::optional< T > MayaFlux::Memory::RingBuffer< T, StoragePolicy, ConcurrencyPolicy, AccessPattern >::pop_lockfree ( )
inlineprivatenoexcept

Definition at line 1045 of file RingBuffer.hpp.

1046 {
1047 auto read = m_state.read_index.load(std::memory_order_relaxed);
1048
1049 if (read == m_state.write_index.load(std::memory_order_acquire)) {
1050 return std::nullopt;
1051 }
1052
1053 T value = m_storage.buffer[read];
1054 m_state.read_index.store(
1055 State::increment(read, m_storage.capacity()),
1056 std::memory_order_release);
1057
1058 return value;
1059 }

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

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

+ Here is the caller graph for this function: