使用twisted的异步任务队列:线程、多核和远程。

AsynQueue的Python项目详细描述


基于Twisted框架的异步任务排队 优先顺序和强大的工作界面。辅助实现 包含用于在主线程中异步运行任务的 单独的线程,在单独的python解释器(多处理)中, 甚至在使用twisted异步消息的独立设备上 协议。

包括延迟迭代功能:调用返回 迭代器可以返回 Deferator 相反,它以一种扭曲友好的方式进行迭代,甚至 通过网络连接。您还可以提供符合 Twisted的IConsumer接口和迭代将按原样提供给它 变得可用。

util模块包含 DeferredTracker 对象,使导入本身具有价值。你可以用 它的put方法跟踪扭曲的Deferred对象,而不插入 任何进入回拨链的东西。然后你可以在非阻塞状态下等待 所有人,任何人,或某些跟踪的推迟发射的扭曲时尚 (又一次,没有与他们的任何回调纠缠不清)使用 跟踪器的deferToAlldeferToAny,和deferUntilFewer 方法。

包括示例包 mcMandelbrot生成 Mandelbrot设置图像,逐行显示 异步多核处理一个实例 ProcessQueue 将每行像素的计算分派给运行 在单独的Python进程上颜色映射的RGB结果是 在它们返回时收集并智能地缓冲以进行迭代 以正确的顺序发送到第三方PNG库 通常玩得很好的扭曲。

您可以在安装后通过运行mcmandelbrot进行尝试。 (有一些选项和参数)从控制台。的输出 脚本是一个png文件,可以通过管道到free feh来查看 图像查看器:只需在命令行末尾添加|feh -

不久前,有人在努力实现python 3的兼容性,但是 它还没有得到支持。

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

推荐PyPI第三方库


热门话题
java按钮在可展开列表视图中不可单击   java类声明对象类型不明确   java使用单独的类从Get和Set方法获取值   java Spring引导集成测试不读取属性文件   java如何为函数中带注释的参数编写mockito   java在调整JFrame的大小时消除了组件之间的额外空间   Java流筛选器空指针问题   为什么java会这么做。util。可选的没有一些和没有子类?   java Android广播接收器作为传递字符串的内部静态类   Java中使用迭代器的集合类型推断?   java在JUnit测试中获取JAR列表   java从命名的Linux管道读取BufferedInputStream只工作一次   java是使用值对地图进行排序的最佳方法   位操作有人知道为什么我的java代码使用n=n/2不能正常工作,而n>>1能正常工作吗?   java数据已从mysql中选择,但该过程引发NullPointerException   java如何将文本从控制台传递到文本编辑器   java如何在不使用adb命令的情况下通过USB连接到pc的安卓设备的互联网连接?   Spring是如何使用Java8类的,但它运行在Java7上的?   java仅仅通过类型参数创建泛型类?