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?
天蓬老师2017-04-18 10:32:27
이런 이유로 함수 데코레이터를 피클할 수 없는 것 같습니다.
이것을 살펴보세요:
데코레이터와 다중 프로세스와 피클
확장: Python MultiProcessing 사용 경험