cs.queues 20181022

some Queue subclasses and ducktypes

Queue-like items: iterable queues and channels.

Class Channel

A zero-storage data passage. Unlike a Queue(1), put() blocks waiting for the matching get().

Function IterablePriorityQueue(capacity=0, name=None, *args, **kw)

Factory to create an iterable PriorityQueue.

Function IterableQueue(capacity=0, name=None, *args, **kw)

Factory to create an iterable Queue.

Class NullQueue

MRO: cs.resources.MultiOpenMixin, cs.obj.O
A queue-like object that discards its inputs. Calls to .get() raise Queue_Empty.

Class PushQueue

MRO: cs.resources.MultiOpenMixin, cs.obj.O
A puttable object which looks like an iterable Queue.

Calling .put(item) calls func_push supplied at initialisation to trigger a function on data arrival, whose processing is mediated queued via a Later for delivery to the output queue.

Class TimerQueue

Class to run a lot of "in the future" jobs without using a bazillion Timer threads.