Python多线程如何设置一个池来作为队列运行任务



我想创建一个池来运行应该遵循队列和顺序的任务。

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

它可以打印一些东西。然而没有一个一个上来。它会立即完成

实际上它在不同的时间运行。但是它会同时显示

最新更新