未知

yamp的Python项目详细描述


#又一个多处理池(yamp)

![许可证gplv3+](https://img.shields.io/badge/license-gplv3+-green.svg)![关于](https://img.shields.io/badge/subject-multiprocessing-orange.svg?风格=社交)![2-pre-alpha](https://img.shields.io/badge/development\u status-2\uu pre--alpha orange.svg)


python模块,用于管理队列的多处理。与"multiprocessing.pool"非常相似,但更符合我的喜好。

这足以将其封装到一个模块中。

或者年轻的流浪汉。无需提及对无家可归者的所有尊重。



加载。
-[]最后一分钟达到核心数时的默认警告
-[]三个值达到核心数时的默认限制
-[x]挂钩。至少,在worker目标执行后允许执行某些内容,但由于是在文件中报告结果的位置而被锁定(例如)。
-[]python 3.5和当前的2.7支持。
-[]cythonize.
-[]查看*pkg_resources*以改进版本编号。
-[x]进入"暂停"模式时,使用"直到"暂停工作人员,直到条件恢复并可以继续工作(然后继续工作)。
-[]这许多人进入"暂停-恢复"循环。提高铃声以减少并行工作线程的数量。
-[]达到限制时触发"暂停",但在"警告已清除"时触发"恢复"。
-[]在内存使用和机器加载的警告部分中,可以对这些工作线程进行重新排序以降低其优先级。



用法:

照常获取源代码。

```
$git clone git@github.com:srgblnch/yamp.git
`````



>;>import yamp
>;>yamp.version()
'0.0.5-0'
>;>argilst=range(20)
>;>checkperiod=2
>;>**2
…:sleep(randint(checkperiod/2,checkperiod*2))
…:return argout
>;>pool=yamp.pool(tester,argilst)
>;>pool.checkperiod=checkperiod
>;>pool.start()
```

检查程序的进度:

``python
>;>pool.progress
0.407407
```

其他人将在58到59秒后收到它。

[0,1,2,3,4,5,6,7,8,9](10)
2016-12-06 19:19:43.323326-调试-yamp-主进程-主线程-3个工作线程就绪
2016-12-06 19:19:44.325203-调试-yamp-主进程-主线程-已请求启动池
2016-12-06 19:19:44.325444-调试-yamp-mainprocess-mainthread-start发出的事件
2016-12-06 19:19:44.325639-info-yamp-mainprocess-monitor2-开始工作:创建fork
2016-12-06 19:19:44.327255-调试-yamp-主进程-监视器2-开始监视
2016-12-06 19:19:44.331702-调试-yamp-进程2-worker2-事件触发后fork开始0:00:00.006179
2016-12-06 19:19:44.331925-调试-yamp-进程2-worker2-argin:0
(…)
2016-12-06 19:20:22.369294-信息-yamp-进程2-工作程序2-参数:0
2016-12-06 19:20:22.370414-调试-yamp-进程2-工作程序2-发出步骤事件
2016-12-06 19:20:22.370479-调试-yamp-主进程-池监视器-步骤事件捕获
2016-12-06 19:20:22.370571-调试-yamp-进程2-工作程序2-精氨酸:1
2016-12-06 19:20:22.371047-调试-yamp-主进程-池监视器-收到步骤事件
2016-12-06 19:20:22.371420-调试-yamp-主进程-池监视器-收集1个输出
2016-12-06 19:20:22.371743-警告-yamp-主进程-池监视器-工作进程0在应该启动时未启动(事件:true,工作进程:false)
2016-12-06 19:20:22.371993-警告-yamp-主进程-池监视器-工作进程1在应该启动时未启动(事件:true,工作进程:false)
(…)
2016-12-06 19:20:43.318191-调试-yamp-主进程-监视器0-等待启动
2016-12-06 19:20:43.318308-信息-yamp-主进程-监视器0-开始工作:创建分叉
2016-12-06 19:20:43.319511-调试-yamp-主进程-监视器0-开始监视
2016-12-06 19:20:43.320754-调试-yamp-主进程-监视器1-等待启动
2016-12-06 19:20:43.320849-信息-yamp-主进程-监视器1-开始工作:创建分叉
2016-12-06 19:20:43.322135-调试-yamp-主进程-mOnitor1-开始监视
2016-12-06 19:20:43.323962-调试-Yamp-处理程序0-Worker0-事件触发后fork开始0:00:58.998431
2016-12-06 19:20:43.324197-调试-Yamp-处理程序0-Worker0-精氨:2
2016-12-06 19:20:43.326832-调试-Yamp-处理ss1-worker1-fork在事件触发后0:00:59.001310启动
2016-12-06 19:20:43.327090-debug-yamp-process1-worker1-argin:3
(…)


*尝试使用"threading.event"而不是"multiprocessing.event"用于"u start"(仅由"mainprocess"使用)改变延迟启动的行为。

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

推荐PyPI第三方库


热门话题
java如何显示因用户而异的SQLite存储数据?   转换java。sql。将映射传递给Jackon的valueToTree方法时StringNode的时间戳   从java中的列表json获取值   unicode Java字符存储在什么编码中?   java如何让Spring数据存储库中的默认方法命中缓存?   java使用readClassDescriptor()和resolveClass()来允许序列化版本控制   数组通过另一个矩阵的一部分填充矩阵   如果包含使用正则表达式的字符串,则替换父XML标记的java   java清除SharedReference中的单个变量   java将变量值从一个jsp页面传输到另一个jsp页面   java JDBC+SQLite:DriveManager不加载所需的驱动程序   相同源代码的java Kotlin构建生成不同的二进制文件   Java中的元组枚举