subprocess.wait()不等待Popen进程完成(使用线程时)?
|
使用
subprocess.Popen()
从我的python脚本使用线程生成同一应用程序的多个实例以使其同时运行时,遇到了一些问题。在每个线程中,我使用popen()
调用来运行应用程序,然后我通过调用wait()
来等待其完成。问题似乎在于wait()
调用实际上并未等待该过程完成。我仅使用一个线程进行了实验,并在进程开始和结束时打印出了文本消息。因此线程函数看起来像这样:
def worker():
while True:
job = q.get() # q is a global Queue of jobs
print(\'Starting process %d\' % job[\'id\'])
proc = subprocess.Popen(job[\'cmd\'], shell=True)
proc.wait()
print(\'Finished process %d\' % job[\'id\'])
job.task_done()
但是,即使我只使用一个线程,它也会在出现任何“已完成进程...”消息之前打印出几条“正在启动进程...”消息。 wait()
实际上没有等待的情况吗?我有几个不同的外部应用程序(C ++控制台应用程序),这些应用程序又将同时运行多个实例,对于某些实例,我的代码有效,但对于其他实例,则不会。外部应用程序是否可能存在某种问题,以某种方式影响对ѭ2的调用?
用于创建线程的代码如下所示:
for i in range(1):
t = Thread(target=worker)
t.daemon = True
t.start()
q.join() # Wait for the queue to empty
更新1:
我还应该补充一点,对于某些外部应用程序,有时会得到-1073471801的返回码(proc.returncode
)。例如,一个外部应用程序将在前两次调用Popen
时给出该返回码,但不会在后两次给出该返回码(当我有四个作业时)。
更新2:
为了解决问题,现在队列中有四个作业,这是四个不同的测试用例。当我运行代码时,对于外部应用程序之一,前两个two9ѭ调用生成返回代码-1073471801。但是,如果我打印出Popen
调用的确切命令,并在命令窗口中运行它,则执行起来不会出现任何问题。
解决了!
我设法解决了自己遇到的问题。我认为问题是我缺乏线程编程经验。我错过了这样一个事实,当我创建了第一个工作线程时,它们会一直存在直到python脚本退出。每次将新项目放在队列中时,我都会错误地创建更多的工作线程(对于要运行的每个外部程序,我都会成批执行)。因此,当我进入第四个外部应用程序时,尽管我只以为有一个线程,但我同时运行了四个线程。
没有找到相关结果
已邀请:
4 个回复
响摔衅幸
代替Popen。即使
,12ѭ也会等待命令完成,然后返回作业的退出代码。
漂汀拦
,
运行子流程时,只会等待
子流程完成,而不会等待命令
。 我将建议是否可以不使用
,如果不可能的话,您可以创建一个类似于此答案的进程组,并使用os.waitpid来等待进程组而不仅仅是shell进程。 希望这对您有所帮助:)
棠媳鳖
骇毖煽洁铂
请注意,这也隐藏了窗口。