超时时杀死或终止子进程？

Question

我想尽可能快地重复执行子过程。但是，有时该过程将花费很长时间，因此我想取消它。我使用signal.signal（…），如下所示：

ppid=pipeexe.pid
signal.signal(signal.SIGALRM, stop_handler)

signal.alarm(1)
.....
def stop_handler(signal, frame):
    print 'Stop test'+testdir+'for time out'
    if(pipeexe.poll()==None and hasattr(signal, "SIGKILL")):
         os.kill(ppid, signal.SIGKILL)
         return False

但有时这段代码将尝试阻止下一轮执行。停止test / home / lu / workspace / 152 / treefit / test2超时/
bin / sh：/ home / lu / workspace / 153 / squib_driver：找不到-这是下一次执行；该程序错误地将其停止。

有谁知道如何解决这个问题？我想停止不执行1秒的时间。sleep（n）通常等待n秒。我不希望我可以执行少于1秒

Answer 1

您可以执行以下操作：

import subprocess as sub
import threading

class RunCmd(threading.Thread):
    def __init__(self, cmd, timeout):
        threading.Thread.__init__(self)
        self.cmd = cmd
        self.timeout = timeout

    def run(self):
        self.p = sub.Popen(self.cmd)
        self.p.wait()

    def Run(self):
        self.start()
        self.join(self.timeout)

        if self.is_alive():
            self.p.terminate()      #use self.p.kill() if process needs a kill -9
            self.join()

RunCmd(["./someProg", "arg1"], 60).Run()

想法是创建一个运行该命令的线程，如果超时超过某个合适的值（在这种情况下为60秒），则将其杀死。