AtomicQueue
- class AtomicQueue(**kwargs)
The AtomicQueue
object implements a queue that can be used from multiple
threads without performing any blocking operations.
Constructors
- class AtomicQueue
- classmethod new(initial_size: int) AtomicQueue
Create a new atomic queue instance.
initial_size
will be rounded up to the nearest power of 2 and used as the initial size of the queue.- Parameters:
initial_size – initial queue size