我有一个异步函数被这样调用:
from multiprocessing import Process
def my_function(arg1, arg2):
print 'Long process begins'
p = Process(target=my_function, args=(arg1, arg2,)).start()
我怎样才能做到这一点?我需要在运行脚本的其余部分之前完成该过程。
我有一个异步函数被这样调用:
from multiprocessing import Process
def my_function(arg1, arg2):
print 'Long process begins'
p = Process(target=my_function, args=(arg1, arg2,)).start()
我怎样才能做到这一点?我需要在运行脚本的其余部分之前完成该过程。
使用p.join()
阻塞调用线程,直到调用其 join() 方法的进程终止或直到发生可选超时。
如果超时为无,则没有超时。
一个进程可以多次加入。
一个进程不能加入自己,因为这会导致死锁。在进程启动之前尝试加入进程是错误的。