我有一个名为parseContents的子进程函数,使用以下代码进行调用:
def main():
p = Process(target=parseContents, args=(event.name,))
p.start()
p.join()
如何利用multiprocessing模块和Queue方法,使得我可以将parseContents中的变量传回到main函数,在p.join()之后使用?
我已经了解到可以使用以下代码:
from multiprocessing import Queue
queue = Queue()
queue.put( myVar ) #obviously this would be inside parseContents()
print queue.get( myVar ) #obviously this would be inside main()
在调用parseContents函数后,我是否需要将“queue”变量/实例传递给它,以便子进程知道队列的存在?
如何正确实现父进程和子进程之间的多进程队列,就像上面的main()
段落中构建的那样?