from multiprocessing import Pool def with_app_context(need_new=False): def magic(func): app_store = {} def wrapper(*args, **kwargs): print 'inside', args, kwargs result = func(*args, **kwargs) return result return 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 使用心得
我已經找到原因了:
子進程異常.
http://stackoverflow.com/ques...