python多进程

 

 

#! /usr/bin/env python
# coding:utf-8

import multiprocessing
import os


if __name__ == "__main__":
pool = multiprocessing.Pool(processes = 3)
for i in xrange():
msg = "echo hello %d ; sleep 1" %(i)
pool.apply_async(os.system, (msg, )) #维持执行的进程总数为processes,当一个进程执行完毕后会添加新的进程进去

print "Mark~ Mark~ Mark~~~~~~~~~~~~~~~~~~~~~~"
pool.close()
pool.join() #调用join之前,先调用close函数,否则会出错。执行完close后不会有新的进程加入到pool,join函数等待所有子进程结束
print "Sub-process(es) done."


您可以选择一种方式赞助本站

发表评论

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen:

图片 表情