使用芹菜作为后端的concurrent.futures.executor实现

celery-executor的Python项目详细描述


芹菜执行器

PyPI version fury.ioBuild StatusRead The DocsPyUP

以芹菜为后端的concurrent.futures.Executor实现

功能

该包提供了一个实现 ^{}

>>>fromcelery_executor.executorsimportCeleryExecutor>>>executor=CeleryExecutor()>>>forresultinexecutor.map(str.upper,['one','two','three']):...print(result)ONETWOTHREE

注意Executor.map()接口可能会导致结果无序, 如果后面的人必须先完成。

注意事项

这个执行器使开发人员免除了标记每个任务的负担。 与芹菜装饰工一起工作,并将这些任务导入到工人身上 事先。但不能免除将代码发送给工作者的责任。

发送到CeleryExecutor.map()的函数应在客户端上可拾取 (呼叫者是.map().submit()),在芹菜上应该是不可吃的。 处理发送的“任务”的工人。例如,无法发送lambdas。

因为芹菜假设开发人员将所需的代码放在工作人员身上, 请确保发送到^ {CD2}}的函数/部分代码存在于 工人。

待完成

  • []记录CeleryExecutor.__init__()非标准额外选项predelaypostdelayapplyasync_kwargs
  • []测试取消未来时取消任务的行为
  • []测试关闭执行器并尝试发送新任务的行为
  • []找到一种方法来测试芹菜任务的运行状态,因为芹菜提供的测试工作人员不会传播芹菜任务的事件

学分

这个包是用Cookiecutter^{}项目模板创建的。

======= 历史记录

0.1.0(2018-05-25)

  • pypi上的第一个版本。

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

推荐PyPI第三方库


热门话题
并行处理java。util。同时发生的叉子在游泳池里。常见的并行性准则,用于选择正确的并行度大小   java如何将空白字符追加到指定长度?   安卓应用程序中出现错误,SSLHandshakeException,找不到证书路径的信任锚点   java如何使用JUnit Mockito验证检查方法是否未被调用   java如何使用不同的@RequestMapping解析多个控制器中的静态页面   Selenium中的javascript需要验证搜索结果   访问数据库SQLiteopenHelper方法时java应用程序崩溃(nullpointerexception)   在二叉树中验证最小堆时出现java空指针异常   Java 7的SSL连接失败   java用RestEasyWebTarget替换ProxyFactory不起作用   在Java应用程序中单击“否”按钮后,数组程序冻结(无响应)   数组中的前缀Java初学者前进和   Java HTML解析器,包括脚本标记和LineNumberReader   在java中为长类型数字加前导零   正则表达式无法映射正则表达式java。lang.IllegalArgumentException:模式段中捕获组的数量