处理输出的回调函数

Question

最近我一直在玩Popen。我在后台生成了一个进程，将输出写入TemporaryFile：

f = tempfile.TemporaryFile()
p = subprocess.Popen(["gatttool"], stdin = subprocess.PIPE, stdout = f)

现在它的工作方式是我通过stdin 向进程发送命令并稍后读取临时文件。而且它是非阻塞的，所以我可以执行其他任务。

问题是gatttool 有时会自己生成一些输出字节（例如通知）。我正在寻找一种在不阻塞TemporaryFile的情况下读取此输出的方法。

我的问题：

1) 从TemporaryFile（50 行）读取输出并希望subprocess 优雅地等待我读取该数据是否安全，或者它会终止吗？

2) 有没有一种优雅的方法来创建一个回调函数，该函数将在TemporaryFile 上的每个事件上调用（而不是让一个线程每秒运行一次并读取数据）？

Answer 1

其实解决方法很简单。创建一个pipe，使用gatttool 输出作为输入。该管道的输出转到thread，它逐行读取该输出，并解析每一行。检查它，它的工作原理。请锁定这个问题。

# Create a pipe. "gatt_in" ins where the "gatttool" will be dumping it's output.
# We read that output from the other end of pipe, "gatt_out"
gatt_out, gatt_in = os.pipe()

gatt_process = subprocess.Popen(["gatttool", "your parametres"], stdin = subprocess.PIPE,
                                stdout = gatt_in)

现在每次我想向gatttool 发送命令时，我都会这样做：

gatt_process.stdin.write("Some commands\n")

此命令的结果将出现在gatt_out 中。就我而言，这是在另一个线程中处理的。

Answer 2

要从子进程提供输入/获取输出，您可以使用subprocess.PIPE：

from subprocess import Popen, PIPE

p = Popen(['gatttool', 'arg 1', 'arg 2'], stdin=PIPE, stdout=PIPE, bufsize=1)
# provide input
p.stdin.write(b'input data')
p.stdin.close()
# read output incrementally (in "real-time")
for line in iter(p.stdout.readline, b''):
    print line,
p.stdout.close()
p.wait()