Skip to main content

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.

Release files for cs-queues 20181022

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for cs-queues 20181022
File Size Uploaded
cs.queues-20181022.tar.gz 5.8 kB Details

Release files / cs.queues-20181022.tar.gz

Download URL cs.queues-20181022.tar.gz
Size 5.8 kB
Tags Source
SHA-256 checksum
How to use checksums
51be1b9a2d59c7d3d50aa949bac563301650a9c97642db14460ba40ed0e6ece5
BLAKE2b-256 checksum
How to use checksums
41ed0c8c274eb0221f3b48903a50f5a02e5e10c7f28ad1ed41e90ea8214dba24
Upload date
Uploaded using Trusted Publishing?
What is trusted publishing?
No
Uploaded via twine/1.11.0 pkginfo/1.4.2 requests/2.18.4 setuptools/40.0.0 requests-toolbelt/0.8.0 tqdm/4.23.0 CPython/3.6.6
Anthropic, PBC Visionary sponsor Bloomberg Visionary sponsor Hudson River Trading Visionary sponsor Meta Visionary sponsor NVIDIA Visionary sponsor Microsoft Sustainability sponsor Depot Continuous Integration AWS Cloud computing and Security Sponsor Datadog Monitoring Fastly CDN Google Download Analytics Sentry Error logging StatusPage Status page