在使用apply_async()函数时,需要添加回调函数(callback),回调函数会在目标函数执行完毕之后自动调用。下面是代码示例:
from multiprocessing import Pool
def target_function(param):
print("this is the target function")
return param
def callback(result):
print("callback function was called with result: ", result)
if __name__ == '__main__':
pool = Pool(processes=1)
result = pool.apply_async(target_function, args=(123,), callback=callback)
print(result.get())
在这个例子中,我们定义了目标函数target_function和回调函数callback。在使用apply_async()函数时,我们将target_function和回调函数callback作为参数传递。当target_function执行完毕后,callback函数会自动被调用。需要注意的是,我们还要调用result.get()来获取目标函数的返回值。