Popen.stdin 存在多线程问题，无法正常工作

Question

我正在尝试从我的 python 程序运行 shell。 我使用了多线程方法，其中接受用户的输入并应通过 shell 执行。

一切似乎都正确，除了程序执行不会发生在标准输入之外。

我不确定我使用 Popen.stdin 的方式是否有问题。

所以请帮忙解决这里出了什么问题。

from subprocess import Popen,PIPE
import shlex
import threading
from Queue import Queue


class MyThread(threading.Thread):
    def __init__(self,func,args):
        threading.Thread.__init__(self)
        self.func=func
        self.args=args

    def run(self):
        apply(self.func,self.args)



def bash(command,output):
    commandList=shlex.split('python test.py')   
    process=Popen(commandList,stdout=PIPE,stdin=PIPE,stderr=PIPE,shell=True)
    print process.stdout.readlines()
    while (process.pole()==None):
        #commandList=shlex.split(command.get(1))
        print 'bash'
        process.stdin.write(command.get(1))
        process.stdin.flush()
        output.put(process.stdout.readlines(),1)
        process.stdout.flush()



def communicate(command,output):
    while True:
        command.put(raw_input('enter command>'))
        print 'communicate'
        print output.get(1)



funcs=[bash,communicate]
nfuncs=len(funcs)    

def main():

    command=Queue(1)
    output=Queue(1)
    threads=[]

    for i in range(nfuncs):
        t=MyThread(funcs[i],(command,output))
        threads.append(t)

    for i in range(nfuncs):
        threads[i].start()

    for i in range(nfuncs):
        threads[i].join()

    print 'successful'       

if __name__=='__main__':
    main()

我给出了下面的输出。

karthik@ubuntu:~/TerminalChatBot/test$ python threadTerminal.py
enter command>ls
communicate

此后不再执行。我什至无法使用 ctrl+c 来停止 python 脚本。它只是挂着。

注意：线程通信需要存在，因为我们需要将此代码与更大的模块集成。

Answer 1

小事情：

它是 process.poll() 而不是 process.pole()。

而不是

 for i in range(nfuncs):
    t=MyThread(funcs[i],(command,output))
    threads.append(t)

do

 for func in nfuncs:
    t=MyThread(func,(command,output))
    threads.append(t)

为什么要运行 python test.py Now？您不想在 shell 中运行 ls communications 吗？在这种情况下您应该执行以下操作：

def bash(command,output):
    process=Popen('bash',stdout=PIPE,stdin=PIPE,stderr=PIPE,shell=True)
    print process.stdout.readlines()
    # I don't really understand what's going on here
    while (process.pole()==None):
        print 'bash'
        process.stdin.write(command.get(1))
        process.stdin.flush()
        output.put(process.stdout.readlines(),1)
        process.stdout.flush()

Answer 2

难道它一直挂在process.stdout.readlines()上吗？也许找不到行结尾。尝试 stdout.read(1) 读取一个字符，看看会发生什么。