У меня есть программа, которая взаимодействует с пользователем (действует как оболочка), и я хочу запустить ее, используя модуль подпроцесса python в интерактивном режиме. Это означает, что я хочу иметь возможность писать в стандартный ввод и сразу же получать вывод из стандартного вывода. Я перепробовал множество предлагаемых здесь решений, но ни одно из них, похоже, не отвечает моим потребностям.

Код, который я написал на основеЗапуск интерактивной команды из Python

import Queue
import threading
import subprocess
def enqueue_output(out, queue):
    for line in iter(out.readline, b''):
        queue.put(line)
    out.close()

def getOutput(outQueue):
    outStr = ''
    try:
        while True: #Adds output from the Queue until it is empty
            outStr+=outQueue.get_nowait()

    except Queue.Empty:
        return outStr

p = subprocess.Popen("./a.out", stdin=subprocess.PIPE, stout=subprocess.PIPE, stderr=subprocess.PIPE, bufsize = 1)
#p = subprocess.Popen("./a.out", stdin=subprocess.PIPE, stout=subprocess.PIPE, stderr=subprocess.PIPE, shell=False, universal_newlines=True)

outQueue = Queue()
errQueue = Queue()

outThread = Thread(target=enqueue_output, args=(p.stdout, outQueue))
errThread = Thread(target=enqueue_output, args=(p.stderr, errQueue))

outThread.daemon = True
errThread.daemon = True

outThread.start()
errThread.start()

p.stdin.write("1\n")
p.stdin.flush()
errors = getOutput(errQueue)
output = getOutput(outQueue)

p.stdin.write("5\n")
p.stdin.flush()
erros = getOutput(errQueue)
output = getOutput(outQueue)

Проблема в том, что очередь остается пустой, как будто нет выходных данных. Только если я напишу в stdin все входные данные, которые программа должна выполнить и завершить, тогда я получу выходные данные (а это не то, что я хочу). Например, если я делаю что-то вроде:

p.stdin.write("1\n5\n")
errors = getOutput(errQueue)
output = getOutput(outQueue)

Есть ли способ сделать то, что я хочу сделать?

РЕДАКТИРОВАТЬ: Скрипт будет работать на машине с Linux. Я изменил свой сценарий и удалил universal_newlines = True +, установил размер буфера в 1 и сбросил stdin сразу после wrtie. Тем не менее я не получаю вывод.

Вторая попытка: Я попробовал это решение, и оно работает для меня:

from subprocess import Popen, PIPE

fw = open("tmpout", "wb")
fr = open("tmpout", "r")
p = Popen("./a.out", stdin = PIPE, stdout = fw, stderr = fw, bufsize = 1)
p.stdin.write("1\n")
out = fr.read()
p.stdin.write("5\n")
out = fr.read()
fw.close()
fr.close()