使用列表循环的示例 #coding: utf-8 import multiprocessing import time def func(msg, msg2): print "msg:", msg time.sleep(3) print "end" print msg2 list = ["test", "hello", "hi", "good", "yes", "well"] if __name__ == "__main__": pool = multiprocessing.Pool(processes = 3) for i in list: msg = "hello" pool.apply_async(func, (msg, i)) #维持执行的进程总数为processes,当一个进程执行完毕后会添加新的进程进去 print "Mark~ Mark~ Mark~~~~~~~~~~~~~~~~~~~~~~" pool.close() pool.join() #调用join之前,先调用close函数,否则会出错。执行完close后不会有新的进程加入到pool,join函数等待所有子进程结束 print "Sub-process(es) done."