def __init__(self, partitions, is_fifo=True):
        self.partitions = [i for i in range(0, partitions)]
        self.partitioner = Crc32NamePartitioner(self.partitions)
        self.logger = logging.getLogger("frontera.contrib.backends.memory.MemoryDequeQueue")
        self.queues = {}
        self.is_fifo = is_fifo
        for partition in self.partitions:
            self.queues[partition] = deque()
Deque-based queue (see collections module). Efficient queue for LIFO and FIFO strategies.
dataset/ETHPy150Open scrapinghub/frontera/frontera/contrib/backends/memory/__init__.py/MemoryDequeQueue.__init__