一些队列子类和ducktype
cs.queues的Python项目详细描述
发布20190812: {QueQueuleTyrult:doMultMixIn。^ {STR 1 } $ init ,以便^ {STR 1 } $ STR 是实用的。
类队列项目:可访问的队列和通道。
类Channel
零存储数据通道。 与队列(1)不同,put()块等待匹配的get()。
函数IterablePriorityQueue(capacity=0, name=None, *args, **kw)
创建iterable priorityqueue的工厂。
函数IterableQueue(capacity=0, name=None, *args, **kw)
工厂创建一个iterable队列。
类NullQueue
mro:cs.resources.MultiOpenMixin
丢弃其输入的类队列对象。
调用.get()raise queue_empty。
方法NullQueue.__init__(self, blocking=False, name=None)
初始化空队列。
参数:
blocking
:如果为true,则调用.get()block until.shutdown()。 默认值:false。name
:此空队列的名称。
类PushQueue
mro:cs.resources.MultiOpenMixin
一个看起来像可iterable队列的puttable对象。
calling.put(item)调用初始化时提供的func_push
在数据到达时触发一个函数,它的处理是中介的
通过稍后的队列传递到输出队列。
方法PushQueue.__init__(self, name, functor, outQ)
用后面的L
,可调用的functor
初始化pushqueue
以及输出队列outQ
。
参数:
functor
是一个一对多函数,它接受一个 输入项并返回输出项;它可以是 发电机。这些输出作为 收到。
类TimerQueue
在不使用大量资源的情况下运行许多“未来”作业 计时器线程。
发布日志
发布20190812: {QueQueuleTyrult:doMultMixIn。^ {STR 1 } $ init ,以便^ {STR 1 } $ STR 是实用的。
发布20181022: 错误修复通道,drastic简化pushqueue,其他小改动。
发布20160828: 在distinfo中使用“install_requires”而不是“requires”。 timerqueue.add:支持func的可选*a和**kw参数。 许多错误修复和内部更改。
发布20150115: 更多的pypi元数据修正。
发布20150111: 初始PYPI发布。