Я пытался понять FIFO, используя Python под Linux, и обнаружил странное поведение, которое я не понимаю.
Ниже приведено fifoserver.py
import sys
import time
def readline(f):
s = f.readline()
while s == "":
time.sleep(0.0001)
s = f.readline()
return s
while True:
f = open(sys.argv[1], "r")
x = float(readline(f))
g = open(sys.argv[2], "w")
g.write(str(x**2) + "\n")
g.close()
f.close()
sys.stdout.write("Processed " + repr(x) + "\n")
, и это fifoclient.py
import sys
import time
def readline(f):
s = f.readline()
while s == "":
time.sleep(0.0001)
s = f.readline()
return s
def req(x):
f = open("input", "w")
f.write(str(x) + "\n")
f.flush()
g = open("output", "r")
result = float(readline(g))
g.close()
f.close()
return result
for i in range(100000):
sys.stdout.write("%i, %s\n" % (i, i*i == req(i)))
Я также создал два FIFO, используя mkfifo input
и mkfifo output
.
Я не понимаю, почему, когда я запускаю сервер (с python fifoserver.py input output
)и клиент (с python fifoclient.py
) из двух консолей после некоторых запросов клиент вылетает с ошибкой «сломанный канал» в f.flush()
.Обратите внимание, что перед сбоем я видел от нескольких сотен до нескольких тысяч правильно обработанных запросов, работающих нормально.
В чем проблема в моем коде?