Class Queue

distributed.comm.inproc.Queue

A single-reader, single-writer, non-threadsafe, peekable queue.

Declaration

class Queue

Documentation

Methods

▷ def __init__(self)
source link
▷ def get(self)
source link
▷ def get_nowait(self)
source link
▷ def peek(self, default=_omitted)
Get the next object in the queue without removing it from the queue.
source link
▷ def put_nowait(self, value)
source link