如何停止部分python程序的运行，而让其余的程序正常执行？

2023-05-30 admin

我试图过早地终止一个函数，但让我的程序的其余部分正常运行。我不被允许更改函数的行为。

我尝试将函数放入一个进程中(使用多进程python库)，然后终止该进程。然而，我从信号库中得到了一个错误。我相信这是因为terminate()函数不会终止父进程的子进程，但我不确定。

任何关于我如何解决这个问题或新方法的帮助都将不胜感激。

def train(self):
    import reaver as rvr
    env = rvr.envs.SC2Env(map_name='MoveToBeacon')
    agent = rvr.agents.A2C(env.obs_spec(), env.act_spec(), rvr.models.build_fully_conv, rvr.models.SC2MultiPolicy, n_envs=4)
    agent.run(env)


def run(self):
    import multiprocessing
    p = multiprocessing.Process(target=self.train, args=())
    p.start()

    import time
    time.sleep(120)
    p.terminate()
    p.join()
    print("hello) # agent.run(env) shouldn't be running here

run()

以下是我收到的错误消息。理想情况下，输出应该是"hello“。

Traceback (most recent call last):
  File "signal.py", line 42, in <module>
    trainingHelper.run()
  File "signal.py", line 34, in run
    p.terminate()
  File "/home/user/miniconda3/lib/python3.6/multiprocessing/process.py", line 116, in terminate
    self._popen.terminate()
  File "/home/user/miniconda3/lib/python3.6/multiprocessing/popen_fork.py", line 56, in terminate
    os.kill(self.pid, signal.SIGTERM)
AttributeError: module 'signal' has no attribute 'SIGTERM'

转载请注明出处:http://www.xiangbinbaiyi.com/article/20230530/1922129.html