手机查看
【代码片段】python 多进程编程
python 多进程编程
import time
from multiprocessing import Process
from multiprocessing import Pool
def task(idx):
print("第%s次执行：%s" % (idx, time.strftime("%H:%M:%S")))
time.sleep(2)
if __name__ == '__main__':
# 1. 普通方式
for index in range(5):
task(index + 1)
# 2. 进程方式
for index in range(5):
p = Process(target = task, args = (index + 1,))
p.start()
# 3. 进程池方式
p = Pool(5)
for index in range(5):
p.apply_async(task, args=(index + 1,))
p.close()
p.join()
三种方式对应执行结果：
- 普通方式
第1次执行：17:56:21
第2次执行：17:56:23
第3次执行：17:56:25
第4次执行：17:56:27
第5次执行：17:56:29
[Finished in 10.3s]
- 进程方式
第2次执行：17:57:23
第1次执行：17:57:23
第3次执行：17:57:23
第4次执行：17:57:23
第5次执行：17:57:23
[Finished in 2.3s]
- 进程池方式
第1次执行：17:57:55
第3次执行：17:57:55
第2次执行：17:57:55
第4次执行：17:57:55
第5次执行：17:57:55
[Finished in 2.5s]
注意事项：
进程和进程池要放在 f __name__ == '__main__': 下执行。
------ 本文结束 感谢阅读 ------