一些队列子类和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是一个一对多函数,它接受一个 输入项并返回输出项;它可以是 发电机。这些输出作为 收到。
  • {< CD15> }是一个通过IT.P.()方法接受的多OpenMIXIN。

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发布。

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
java jgrapht SimpleDirectedWeightedGraph规范化权重   java安卓使用CFB   java如何从javaclass警告浏览器?可能吗?   javagson结构难点   java使用jbossclient的最佳方式是什么。Wildfly 10应用程序中的jar?   JAVA:socket重写以使用CipherInputStream和CipherOutputStream   java Android UI测试长时间点击并拖动   java如何在Android中重置AtomicInteger唯一Id?   多线程客户端/服务器应用程序上的java客户端断开连接   GAE Memcache中的java损坏值   java如何使用变量作为资源的路径?   爪哇?(三向)操作员