将数据连续发送到子进程

Question

我正在测试与子进程的通信。我必须启动一个服务器，定期发送数据。最终目标是获取气象数据和绘图服务器的过程。采样率的顺序或分钟....我写了这两段代码，以了解python的基本知识，但我甚至无法使他们的工作。 同步性不是问题。

主处理

import sys, time 
from subprocess import Popen, PIPE 

print 'starting' 
proc = Popen (['python.exe', 
    'C:\Documents and Settings\Administrator\Desktop\sub.py'], 
       stdin = PIPE, stdout = PIPE) 
print 'launched' 

w = 0 
while True: 
    w += 1 
    time.sleep (2) 
    print 'writing', w 
    proc.stdin.write (repr(w)) 
    proc.stdin.flush() 
    print proc.stdout.read() 

子过程：

import sys, time 

print 'reading' 
v = 0 
while True: 
    v = sys.stdin.read() 
    sys.stdout.write('ACK') 
    sys.stdout.flush() 
    time.sleep (4) 

主要过程被阻断，显然子不读取-发送ACK。 我在哪里错了？感谢

Answer 1

到sys.stdin.read()块的调用，因为它试图读取整个流，因此不能返回，直到流被关闭。

尝试使用sys.stdin.readline()，并在使用sys.stdout.write()（在这两个过程中）写入时添加换行符，例如， sys.stdout.write('ACK\n')。这应该确保读取命令只会被阻塞直到读取一行。