3

我有一个 python 脚本，它使用 subprocess 模块打开一个 .exe 程序。这个 .exe 程序是一个无限迭代的脚本，它会继续打印每次迭代的结果，直到用户关闭窗口。每隔一段时间，它就会将迭代结果打印到文件中，替换文件中的先前数据。

我的目标是：

  1. 运行 .exe 程序，并测试它输出的文件是否存在。
  2. 一旦文件显示存在，我需要对文件运行测试以查看迭代是否收敛到给定的容差范围内。一旦迭代收敛，我需要终止 .exe 子进程。

这是我当前的代码。它旨在在创建迭代文件后终止子进程：

import subprocess
from subprocess import Popen, PIPE

fileexists = False

iteratecomms = Popen('iterate.exe', stdout=PIPE, stdin=PIPE, stderr=PIPE)

# Begin the iteration. Need to select options 1 and then 1 again at program menu
out, err = iteratecomms.communicate("1\n1\n".encode())

while (fileexists == False):
    fileexists = os.path.exists(filelocation)
else:
    Popen.kill(iteratecomms)

我知道这是不正确的；问题是，只要我启动该out, err = iteratecomms.communicate("1\n1\n".encode())行，程序就会开始迭代，并且不会继续执行下一组 python 代码。本质上，我需要启动 .exe 程序，同时测试文件是否已创建。但是，我不能这样做，因为程序会无限期地运行。

我怎么能解决这个问题？我假设继续进行第 2 步（测试文件并在某些条件下终止子进程）不会在此之上花费太多工作；如果这不是真的，我将如何完成我的所有目标？

非常感谢你的帮助！

编辑：澄清外部文件被覆盖。

4

2 回答 2

1

假设您正在尝试不断尝试读取此文件，我建议您在有tail问题的文件上运行 a 。这可以从任何 *nix 系列操作系统中的单独终端完成，否则我会查看这篇文章以了解 Python 实现：

http://code.activestate.com/recipes/157035-tail-f-in-python/

之后，如果你想杀死正在运行的程序，你应该能够在正在运行的进程上调用终止：

import subprocess
sub = subprocess.popen(#Whatever)

#Do something

sub.terminate()
于 2013-07-15T18:53:01.530 回答
1

我会使用多处理模块。

pool = multiprocessing.Pool()
def start_iteration():
    return Popen('iterate.exe', stdout=PIPE, stdin=PIPE, stderr=PIPE)
pool.apply_async(start_iteration)
while (fileexists == False):
    fileexists = os.path.exists(filelocation)
Popen.kill(???)

现在唯一的问题是，您必须以某种方式找到进程的 PID，而无需等待 Popen 返回（因为 Popen 永远不应该返回。）

于 2013-07-15T19:06:57.520 回答