一些队列子类和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第三方库


热门话题
Docker&SeleniumJava:无法在Docker容器上运行的chrome浏览器中上载图像/文件   在python中运行java命令   Java垃圾收集器异常行为   java java是否根据底层操作系统执行字节码级优化?   java是否可以休眠自定义查询返回映射而不是列表?   java Spring引导RabbitMQ接收器Jackson反序列化到POJO   apache flex在ActionScript3中创建对象相等“HashMap”作为java HashMap   java如何在Eclipse集成中切换JProfiler启动器   缓存JSP页面结果的java最佳实践?   java集成jaxb绑定文件,使用CXF生成基于WSDL的客户端   java为什么在上传操作结束之前,客户端没有检测到HttpServletResponse的PrintWriter内容?   java在接口内创建类和在类内创建接口有什么用   java向文件写入错误Android Studio   java合并多个RealmList并对结果列表排序?   谷歌API视觉java。lang.NoSuchMethodError   java如何使用逗号分别存储每个值,然后将它们存储到单独的数组中?