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."

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