我想创建一个池来运行应该遵循队列和顺序的任务。
import multiprocessing
import time
def func(msg):
for i in xrange(3):
print msg
time.sleep(2)
if __name__ == "__main__":
pool = multiprocessing.Pool(processes=1)
for i in xrange(10):
msg = "hello %d" %(i)
pool.apply_async(func, (msg, ))
pool.close()
time.sleep(50);
print "Sub-process(es) done."
它可以打印一些东西。然而没有一个一个上来。它会立即完成
实际上它在不同的时间运行。但是它会同时显示