python - 当装饰器遇到multiprocessing, 出了点bug.

问题描述

from multiprocessing import Pooldef with_app_context(need_new=False): def magic(func):app_store = {}def wrapper(*args, **kwargs): print ’inside’, args, kwargs result = func(*args, **kwargs) return resultreturn wrapper return magic@with_app_context(need_new=True)def func(k1, k2): print k1, k2 return ’ret’pool = Pool(processes=1)pool.apply_async(func, args=(’hi’, ’yo’))pool.close()pool.join()

什么结果都不输出, 请问哪有bug?

问题解答

似乎是这个原因，函数装饰器不可pickle 可以看看这个：装饰器与多进程以及Pickle

扩展: Python MultiProcessing 使用心得

我已经找到原因了:

Traceback (most recent call last): File 'wrapper.py', line 30, in <module> print ret.get() File '/System/Library/Frameworks/Python.framework/Versions/2.7/lib/python2.7/multiprocessing/pool.py', line 567, in get raise self._valuecPickle.PicklingError: Can’t pickle <type ’function’>: attribute lookup __builtin__.function failed

子进程异常.

http://stackoverflow.com/ques...