View on GitHub
Install in Dash
AtomicUnboundedSPSCQueue Class Reference
AtomicUnboundedSPSCQueue
public final class AtomicUnboundedSPSCQueue<T> : AtomicUnboundedQueueProtocolA FIFO queue that is safe to share between a single producer and a single consumer.
This is an implementation of unbounded SPSC queue
from 1024cores.net,
with a modification for caching nodes lifted from Rust’s stdlib.
-
Declaration
Swift
public typealias Element = T -
Declaration
Swift
@inlinable public convenience init() -
Declaration
Swift
@inlinable public init(cacheCapacity: Int) -
Declaration
Swift
@inlinable public var isEmpty: Bool { get } -
Declaration
Swift
@inlinable public func push(_ value: T) -
Declaration
Swift
@inlinable public func pop() -> T?