Python中文网 - 问答频道, 解决您学习工作中的Python难题和Bug
Python常见问题
我必须做一个程序，读取一个PDF，转换成PNG文件的每一页，然后运行一些并行代码的每一个图像的每一页。我正在寻找一种方法来创建一个父进程，其中子进程的数目是恒定的。你知道吗
父亲必须给孩子们送工作。如果父亲有21页要处理，并且只有5个孩子，那么父亲必须管理一个队列来发送工作，而不杀死5个孩子并创建新的孩子。当孩子完成工作后，他给父亲发了一封信，让他做新的工作。你知道吗
我不想杀死子进程，因为我认为这比杀死并创建新的子进程或子进程要快。我走错方向了？你知道吗
我试着用多处理.apply\u async，但我没有找到我需要的方法。你知道吗
一些建议或指导？你知道吗
对不起，我的英语不好
我要做的是：
from multiprocessing import Pool
import time
import random
def BarcodeSearcher(x):
#Here goes the image processing
return x*x
def resultCollector(result):
print result
def main():
pool = Pool(processes=3)
for pag in range(3):
pool.apply_async(BarcodeSearcher, args = (pag, ), callback = resultCollector)
pool.close()
pool.join()
if __name__ == '__main__':
main()
Tags： 方法importasync进程maindef孩子result
热门问题
- 尽管Python中的所有内容都是引用，为什么Python导师在没有指针的列表中绘制字符串和整数？
- 尽管python中的表达式为false，但循环仍在运行
- 尽管python代码正确，但从nifi ExecuteScript处理器获取语法错误
- 尽管Python在Neovim中工作得很好，但插件不能识别Neovim中的Python主机
- 尽管python字典包含了大量的条目，但它并没有增长
- 尽管python说模块存在，为什么我会得到这个消息？
- 尽管setuptools和控制盘是最新的，但无法识别singleversionexternallymanaged
- 尽管stdout和stderr重定向，但未捕获错误消息
- 尽管Tensorboard的事件太大，但Tensorboard的步骤太少了
- 尽管tkinter上的变量已更改，但显示未更改
- 尽管try/except使用Python进行单元测试时出现断言错误
- 尽管URL是sam，但仍会抛出“达到最大重定向”
- 尽管url有效，Pandas仍读取url的\u csv错误
- 尽管while中存在时间延迟，但LINUX线程的CPU利用率为100%（1）
- 尽管x0在范围内，Scipy优化仍会引发ValueError
- 尽管xpath正确，但使用selenium单击链接仍不起作用
- 尽管下载了ffmpeg并设置了路径变量python，但没有后端错误
- 尽管下载了i，但找不到型号“fr”
- 尽管下载了plotnine包，但未获取名为“plotnine”的模块时出错
- 尽管为所有行指定了权重，网格（0）仍不起作用
热门文章
- Python覆盖写入文件
- 怎样创建一个 Python 列表？
- Python3 List append()方法使用
- 派森语言
- Python List pop()方法
- Python Django Web典型模块开发实战
- Python input() 函数
- Python3 列表(list) clear()方法
- Python游戏编程入门
- 如何创建一个空的set?
- python如何定义(创建)一个字符串
- Python标准库 [The Python Standard Library by Ex
- Python网络数据爬取及分析从入门到精通（分析篇）
- Python3 for 循环语句
- Python List insert() 方法
- Python 字典(Dictionary) update()方法
- Python编程无师自通 专业程序员的养成
- Python3 List count()方法
- Python 网络爬虫实战 [Web Crawler With Python]
- Python Cookbook（第2版）中文版
你现在的工作方式应该很好。
multiprocessing.Pool创建一个具有固定数量工作进程的池，所有工作进程都将在Pool的生存期内保持活动状态。Pool有一个内部队列，用于在其中一个工作进程完成工作后立即将工作项发送给工作进程。因此，您所需要做的就是将所有您想要完成的工作输入到Pool，然后Pool将处理所有这些工作进程的分发。你知道吗考虑一下你的例子，除了现在我们给它30个工作项：
输出如下：
如你所见，工作在你的工人之间分配，而你不必做任何特殊的事情。你知道吗
相关问题 更多 >
编程相关推荐