Python mantichora包_程序模块 - PyPI

一个简单的多处理接口

mantichora的Python项目详细描述

曼蒂科拉

一个简单的多处理界面

mantichora提供了一个简单的接口 多处理

frommantichoraimportmantichorawithmantichora()asmcore:mcore.run(func1)mcore.run(func2)mcore.run(func3)mcore.run(func4)results=mcore.returns()

 100.00% :::::::::::::::::::::::::::::::::::::::: |    12559 /    12559 |:  func1
  71.27% ::::::::::::::::::::::::::::             |    28094 /    39421 |:  func2
  30.34% ::::::::::::                             |    28084 /    92558 |:  func3
  35.26% ::::::::::::::                           |    27282 /    77375 |:  func4

您可以简单地给mantichora提供运行所需的任意多个函数。 mantichora将使用并给你函数的返回值。这个返回值按函数的顺序排序最初是给曼蒂科拉的。进度条来自 atpbar可用于功能。

这个包中的代码最初是在子包中开发的并发 alphatwirl

此文件中的示例也可以在jupyter笔记本上运行。< BR>

要求
安装
用户指南
- 快速启动
  - 导入库
  - 定义任务函数
  - 与mantichora同时运行任务rel="nofollow">与mantichora同时运行任务
- 功能
许可证
联系人

要求

python 2.7、3.6或3.7

安装

您可以使用conda forge中的conda安装：

conda install -c conda-forge mantichora

或使用pip：

pip install -U mantichora

用户指南

快速启动

我将在这里通过简单的例子演示如何使用mantichora。

导入库

我们将使用两个python标准库时间和在一个例子中随机。任务函数。在示例任务函数中，我们还将使用对于进度条，请使用atpbar。导入这些包并mantichora

importtime,randomfromatpbarimportatpbarfrommantichoraimportmantichora

定义任务函数

让我们定义一个简单的任务函数。

deftask_loop(name,ret=None):n=random.randint(1000,10000)foriinatpbar(range(n),name=name):time.sleep(0.0001)returnret

此函数的任务是睡眠0.0001秒从1000和 10000。atpbar用于显示进度条。函数接受两个参数：name，进度条上的标签，以及函数的返回值。

注意：曼蒂科拉使用多处理在后台进程中运行任务函数。因此，任务函数、它们的参数和返回值必须是可pickle

您只需尝试在不使用mantichora的情况下运行此函数即可。

result=task_loop('task1','result1')

这不会立即返回。它等待函数完成。您将看到一个进度条。

 100.00% :::::::::::::::::::::::::::::::::::::::: |    58117 /    58117 |:  task1

返回值存储在result

print(result)

frommantichoraimportmantichorawithmantichora()asmcore:mcore.run(func1)mcore.run(func2)mcore.run(func3)mcore.run(func4)results=mcore.returns()

与mantichora同时运行任务

现在，我们与mantichora同时运行多个任务。

frommantichoraimportmantichorawithmantichora()asmcore:mcore.run(func1)mcore.run(func2)mcore.run(func3)mcore.run(func4)results=mcore.returns()

在上面的示例代码中，mantichora用可选参数nworkers。nWorkers指定工人们。在上面的例子中是3。默认值为4。AT 大多数任务（如nWorkers任务）都可以并发运行。

with语句" rel="nofollow">with 声明在示例中使用。这样可以确保mantichora正确结束工作。

您可以将任务函数及其参数赋给mcore.run（）。你可以根据需要多次调用mcore.run（）。在上面例如，mcore.run（）使用与不同的论点。每次也可以使用不同的函数。 mcore.run（）立即返回；它不会等待任务完成甚至开始。在每个调用中，mcore.run（）只放置一个任务在队列中后台进程中的工作人员从排队并运行。

mcore.returns（）等待所有任务完成并返回返回值，按任务的顺序排序最初给mcore.run（）

进度条将由atpbar显示。

frommantichoraimportmantichorawithmantichora()asmcore:mcore.run(func1)mcore.run(func2)mcore.run(func3)mcore.run(func4)results=mcore.returns()

不管顺序如何，结果都按原始顺序排序在其中，任务已完成。

frommantichoraimportmantichorawithmantichora()asmcore:mcore.run(func1)mcore.run(func2)mcore.run(func3)mcore.run(func4)results=mcore.returns()

frommantichoraimportmantichorawithmantichora()asmcore:mcore.run(func1)mcore.run(func2)mcore.run(func3)mcore.run(func4)results=mcore.returns()

功能

不带

和语句
end（）。
如果不将与语句一起使用，则需要调用end（）
frommantichoraimportmantichorawithmantichora()asmcore:mcore.run(func1)mcore.run(func2)mcore.run(func3)mcore.run(func4)results=mcore.returns()5
frommantichoraimportmantichorawithmantichora()asmcore:mcore.run(func1)mcore.run(func2)mcore.run(func3)mcore.run(func4)results=mcore.returns()6
terminate（）
mantichora可以用terminate（）终止。在terminate（）之后
调用时，end（）仍需要调用。在下面的例子中，
terminate（）在某些任务睡眠0.5秒后调用
仍在运行。
frommantichoraimportmantichorawithmantichora()asmcore:mcore.run(func1)mcore.run(func2)mcore.run(func3)mcore.run(func4)results=mcore.returns()
7
当任务终止时，进度条停止。
frommantichoraimportmantichorawithmantichora()asmcore:mcore.run(func1)mcore.run(func2)mcore.run(func3)mcore.run(func4)results=mcore.returns()8
任务完成时接收结果
而不是在收到
鲁尔斯，你可以在任务完成后用这个方法得到结果
receive_one（）或receive_receive（）
接收一个（）
方法receive_one（）返回一对运行id和
任务函数的值。如果没有任务完成，receive_one（）
等待一个任务完成。receive_one（）返回无
任务尚未完成。方法返回
任务：
frommantichoraimportmantichorawithmantichora()asmcore:mcore.run(func1)mcore.run(func2)mcore.run(func3)mcore.run(func4)results=mcore.returns()
9
 100.00% :::::::::::::::::::::::::::::::::::::::: |    12559 /    12559 |:  func1
  71.27% ::::::::::::::::::::::::::::             |    28094 /    39421 |:  func2
  30.34% ::::::::::::                             |    28084 /    92558 |:  func3
  35.26% ::::::::::::::                           |    27282 /    77375 |:  func4
0
runid是按以下任务顺序排列的运行id列表
已被赋予run（）
 100.00% :::::::::::::::::::::::::::::::::::::::: |    12559 /    12559 |:  func1
  71.27% ::::::::::::::::::::::::::::             |    28094 /    39421 |:  func2
  30.34% ::::::::::::                             |    28084 /    92558 |:  func3
  35.26% ::::::::::::::                           |    27282 /    77375 |:  func4
1
 100.00% :::::::::::::::::::::::::::::::::::::::: |    12559 /    12559 |:  func1
  71.27% ::::::::::::::::::::::::::::             |    28094 /    39421 |:  func2
  30.34% ::::::::::::                             |    28084 /    92558 |:  func3
  35.26% ::::::::::::::                           |    27282 /    77375 |:  func4
2
对按任务完成的顺序排列。
 100.00% :::::::::::::::::::::::::::::::::::::::: |    12559 /    12559 |:  func1
  71.27% ::::::::::::::::::::::::::::             |    28094 /    39421 |:  func2
  30.34% ::::::::::::                             |    28084 /    92558 |:  func3
  35.26% ::::::::::::::                           |    27282 /    77375 |:  func4
3
 100.00% :::::::::::::::::::::::::::::::::::::::: |    12559 /    12559 |:  func1
  71.27% ::::::::::::::::::::::::::::             |    28094 /    39421 |:  func2
  30.34% ::::::::::::                             |    28084 /    92558 |:  func3
  35.26% ::::::::::::::                           |    27282 /    77375 |:  func4
4
接收完成（）
方法receive_finished（）返回运行ID对的列表
以及已完成任务函数的返回值。方法
receive_finished（）不等待任务完成。它返回一个
如果没有任务完成，则为空列表。
 100.00% :::::::::::::::::::::::::::::::::::::::: |    12559 /    12559 |:  func1
  71.27% ::::::::::::::::::::::::::::             |    28094 /    39421 |:  func2
  30.34% ::::::::::::                             |    28084 /    92558 |:  func3
  35.26% ::::::::::::::                           |    27282 /    77375 |:  func4
5
 100.00% :::::::::::::::::::::::::::::::::::::::: |    12559 /    12559 |:  func1
  71.27% ::::::::::::::::::::::::::::             |    28094 /    39421 |:  func2
  30.34% ::::::::::::                             |    28084 /    92558 |:  func3
  35.26% ::::::::::::::                           |    27282 /    77375 |:  func4
6
runid再次是按任务顺序排列的运行id列表
给了run（）
 100.00% :::::::::::::::::::::::::::::::::::::::: |    12559 /    12559 |:  func1
  71.27% ::::::::::::::::::::::::::::             |    28094 /    39421 |:  func2
  30.34% ::::::::::::                             |    28084 /    92558 |:  func3
  35.26% ::::::::::::::                           |    27282 /    77375 |:  func4
1
 100.00% :::::::::::::::::::::::::::::::::::::::: |    12559 /    12559 |:  func1
  71.27% ::::::::::::::::::::::::::::             |    28094 /    39421 |:  func2
  30.34% ::::::::::::                             |    28084 /    92558 |:  func3
  35.26% ::::::::::::::                           |    27282 /    77375 |:  func4
2
对也按任务完成的顺序再次出现。
 100.00% :::::::::::::::::::::::::::::::::::::::: |    12559 /    12559 |:  func1
  71.27% ::::::::::::::::::::::::::::             |    28094 /    39421 |:  func2
  30.34% ::::::::::::                             |    28084 /    92558 |:  func3
  35.26% ::::::::::::::                           |    27282 /    77375 |:  func4
3
conda install -c conda-forge mantichora
0
日志记录
登录后台进程将传播到
日志记录的a部分描述的方法
食谱
下面是一个简单的示例任务函数，它使用日志记录。任务
函数在返回前进行日志记录。
conda install -c conda-forge mantichora
1
将日志记录流设置为字符串流，以便我们以后可以
以字符串形式检索日志。
conda install -c conda-forge mantichora
2
运行任务。
conda install -c conda-forge mantichora
3
conda install -c conda-forge mantichora
4
在后台进程中的任务函数中进行的日志记录被发送到
在字符串流中写入的主进程。
conda install -c conda-forge mantichora
5
conda install -c conda-forge mantichora
6
许可证
Mantichora根据BSD许可证获得许可。
联系人
大坂村-tai.sakuma@gmail.com
标签：
函数
run
import
conda
func2
func1
mcore
欢迎加入QQ群-->： 979659372
                                    
推荐PyPI第三方库
atd-args-util
可重用的python脚本参数解析器。
glog2
简单的google风格的python日志包装。从benley/python glog派生
itkdb
与itk db接口的python包装器。
wmowonen.theme
世界气象组织Wonen NH主题（2014）
django-closuretree
django的高效树型数据结构
django-digest
django的http摘要身份验证的实现。
django-kvtags
django的可扩展键值标记
regenwolken
开源自托管CloudApp
punt
监视文件更改，并对更改运行脚本。
sseclient-p
用于python的sse客户端
jupyter-docx-bundler
将笔记本导出为docx文件的jupyter bundler扩展名
Webflowp
python webflow cms api客户端
djaodjin-multitier
多层django应用程序
PyQuadTree
用于gis或渲染的纯python四叉树空间索引。
ucivms
ubuntu持续集成虚拟机工具。

导 航 栏

                                            项目 描述
                                        

                                            版本历史
                                        

                                                下载文件
                                            
项目 链接
首页
                                    
标 签
许可证: BSD许可证（BSD 3条款）
作者信息:: 暂无
                                
                            
维护者

                                  tai.sakuma
                                
最新PyPI项目
italian_vip_says
UFx
vofs
fake_item_generator
NerEva
django-monologue
fio_product_attribute_strict
climailsystem
pyshape
tbb-devel
npy-append-arra
anthill.tal.macrorenderer
odoo11-addon-stock-a
uuuu
contextil
fyl_nester
appomatic_renderable
teacher
chuletas
slackbot_ce
最新Python常见问题
我是否正确构建了这个递归神经网络
我是否正确理解acquire和realease是如何在python库“线程化”中工作的
我是否正确理解Keras中的批次大小？
我是否正确理解PyTorch的加法和乘法？
我是否正确组织了我的Django应用程序？
我是否正确计算执行时间？如果是这样，那么并行处理将花费更长的时间。这看起来很奇怪
我是否每次创建新项目时都必须在PyCharm中安装numpy？（安装而不是导入）
我是否每次运行jupyter笔记本时都必须重新启动内核？
我是否用python安装了socks模块？
我是否真的需要知道超过一种语言，如果我想要制作网页应用程序？
我是否缺少spaCy柠檬化中的预处理功能？
我是否缺少给定状态下操作的检查？
我是否能够使用函数“count（）”来查找密码中大写字母的数量(（Python）
我是否能够使用用户输入作为colorama模块中的颜色？
我是否能够创建一个能够添加新Django.contrib.auth公司没有登录到管理面板的用户？

mantichora 0.9.5

mantichora的Python项目详细描述

曼蒂科拉

要求

安装

用户指南

快速启动

导入库
我们将使用两个python标准库时间和在一个例子中随机。任务函数。在示例任务函数中，我们还将使用对于进度条，请使用atpbar。导入这些包并`mantichora`
importtime,randomfromatpbarimportatpbarfrommantichoraimportmantichora

与mantichora同时运行任务

功能

`end（）`。

`terminate（）`

任务完成时接收结果
而不是在收到鲁尔斯，你可以在任务完成后用这个方法得到结果 `receive_one（）`或`receive_receive（）`

`接收一个（）`

`接收完成（）`

日志记录

许可证

联系人

推荐PyPI第三方库

atd-args-util

glog2

itkdb

wmowonen.theme

django-closuretree

django-digest

django-kvtags

regenwolken

punt

sseclient-p

jupyter-docx-bundler

Webflowp

djaodjin-multitier

PyQuadTree

ucivms

导航栏

项目链接

标签

维护者

最新PyPI项目

最新Python常见问题

mantichora 0.9.5

mantichora的Python项目详细描述

曼蒂科拉

要求

安装

用户指南

快速启动

导入库 我们将使用两个python标准库 时间和 在一个例子中随机。 任务函数。在示例任务函数中，我们还将使用 对于进度条，请使用atpbar。 导入这些包并mantichoraimporttime,randomfromatpbarimportatpbarfrommantichoraimportmantichora

与mantichora同时运行任务

功能

end（）。

terminate（）

任务完成时接收结果 而不是在收到 鲁尔斯，你可以在任务完成后用这个方法得到结果 receive_one（）或receive_receive（）

接收一个（）

接收完成（）

日志记录

许可证

联系人

推荐PyPI第三方库

atd-args-util

glog2

itkdb

wmowonen.theme

django-closuretree

django-digest

django-kvtags

regenwolken

punt

sseclient-p

jupyter-docx-bundler

Webflowp

djaodjin-multitier

PyQuadTree

ucivms

导 航 栏

项目 链接

标 签

维护者

最新PyPI项目

最新Python常见问题

导入库
我们将使用两个python标准库时间和在一个例子中随机。任务函数。在示例任务函数中，我们还将使用对于进度条，请使用atpbar。导入这些包并`mantichora`
importtime,randomfromatpbarimportatpbarfrommantichoraimportmantichora

`end（）`。

`terminate（）`

任务完成时接收结果
而不是在收到鲁尔斯，你可以在任务完成后用这个方法得到结果 `receive_one（）`或`receive_receive（）`

`接收一个（）`

`接收完成（）`

导航栏

项目链接

标签