我想使用Python的多处理模块来启动一个新进程,该进程创建一些其他对象并调用该对象的loops_forever方法。
在我的主课中,我有:
import OtherService
from multiprocessing import Process
my_other_service = OtherService(address=ADDRESS)
my_other_process = Process(target=my_other_service.loops_forever())
print("got here")
my_other_process.start()
print("done")
当我运行此代码时,“到达这里”永远不会被打印。 Loops_forever 在“到达这里”打印上方被调用,并且控制永远不会返回到我的主类。
我在这里做错了什么?
我以前以这种方式使用过多重处理:
my_other_process = Process(target=OtherService, kwargs={"address":ADDRESS})
my_other_process.start()
它正确调用 OtherService 的 init 函数并将 init 函数作为单独的进程运行。
唯一的区别是这次我想调用 init 函数,然后作为单独的进程永远运行loops_forever 方法。
当你这样做时target=my_other_service.loops_forever()
,你打电话给loops_forever
。要将其作为函数传递,而不是调用它,您可以删除括号,例如target=my_other_service.loops_forever
.
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)