from multiprocessing import Pool # 导入进程池模块
import os # 导入系统模块
import time # 导入时间模块
import random
def to_work(num):
# 打印进程号
print("----开始执行任务%d,进程的pid为%d,父进程的pid为%d----" % (num, os.getpid(), os.getppid()))
# 模拟延时 random.random() 生成0-1之间的数
time.sleep(random.random())
print("第%d号进程完成任务%d第一阶段" % (os.getpid(), num))
time.sleep(random.random())
print("第%d号进程完成任务%d第二阶段" % (os.getpid(), num))
time.sleep(random.random())
print("第%d号进程完成任务%d第三阶段" % (os.getpid(), num))
time.sleep(random.random())
print("----任务%d执行完毕----" % (num))
def main():
# 创建一个最多开启3进程的进程池
po = Pool(3)
# 将5个任务添加到进程池
for i in range(1, 6):
# async非堵塞添加,to_work为参数名,i为传递的参数,单个参数一定要加逗号!一定要加逗号!一定要加逗号!
po.apply_async(to_work, (i,))
print("----开始----")
# 关闭进程池,不再接收新的任务,开始执行任务
po.close()
# 主进程等待所有子进程结束
po.join()
print("----结束----")
if __name__ == "__main__":
main()
Python多任务代码示例
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
- 文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
推荐阅读更多精彩内容
- 需求 目标：一套代码分成不同的分支版本，在同一个工程下管理这几个版本。 多个分支版本之间，通常有以下异同： 不同版...
- python多线程编程特别适用于完成相互独立的任务，同时进行，相互之间没有依赖性。比如，下面我们介绍的从网站中查询...
