multiprocessing 的 debug 问题？

#-*-coding:utf-8-*-
import multiprocessing
from multiprocessing import Pool,Process,Queue
import time
import pdb

def add(i,item,queue):
    item["i"] = i
    queue.put(item)

def store(queue):
    time.sleep(1)
    while True:
        print queue.get()

if __name__ == "__main__":
    item = {}
    manager = multiprocessing.Manager()
    queue = manager.Queue()
    pool = Pool()
    pool.apply_async(store,args = (queue,))
    try:
        for i in range(10):
            pool.apply_async( add, args = (i,item,queue,"这里多了个参数但没任何错误提示"))
            #pool.apply_async( add, args = (i,item,queue)) #这样可以正常运行
    except Exception,e:
        print Exception,":",e
    time.sleep(2)
    pool.terminate()
    pool.join()

第 1 条附言 · 2016-10-25 15:44:21 +08:00

用 try 把函数里的代码包起来就好了，不知道为啥不包就不报错。

Queue

pool

item

import

1 条回复

GeekGao

2016-10-26 14:54:32 +08:00

没执行到 add 方法里啊，你 apply_async 调用过后.get() 执行后就知道有报错了啊

multiprocessing 的 debug 问题 ？

multiprocessing 的 debug 问题？