自己写的一个简单的python管道传信息的例子，程序一会能读出并打印信息，一会读不到

qqrilxk

不知哪里出了问题，感觉程序中线程readfifo一会能从管道中读到信息，一会读不到，不知什么原因，该怎么修改呢？
写进程writefifo在退出后，读线程readfifo应该还是可读到的，可现在很不稳定，请大侠指教，谢谢。
import os,multiprocessing, thread, threading,time
def readfifo():
        fd = os.open('testpipe',os.O_NONBLOCK|os.O_RDWR)
        while True:       
                time.sleep(1)
                try:
                        mess = os.read(fd,20)
                        if mess:
                                print mess
                       
                except Exception,e:
                        pass
                               
def writefifo():
        fd = os.open('testpipe',os.O_NONBLOCK|os.O_RDWR)
        os.write(fd,"haha")
#        time.sleep(5)
#        os.close(fd)
#        while True:
#                #time.sleep(20)
#                continue


pipe = 'testpipe'
if os.path.exists(pipe):
        os.unlink(pipe)
os.mkfifo(pipe)

p = multiprocessing.Process( target=writefifo, args=() )
p.start()

t = threading.Thread( target=readfifo, args=(), name='readfifo' )
t.start()

while True:
        time.sleep(10)
#        os._exit(-1)

cdtits

试试 python 3

106033177

回复 1# qqrilxk
命名管道不能读写打开，要么打开写，要么打开读。

   

wfnh

果断用队列

qqrilxk

106033177 发表于 2012-08-30 15:07
回复 1# qqrilxk
命名管道不能读写打开，要么打开写，要么打开读。

我一开始也是这样，要么打开写，要么打开读，可是运行出问题，具体问题是啥不记得了，网上很多网友也是这么反映的，但没找到原因。因此就改成了读写方式。我是在python2.6下，

linux_c_py_php

一看就不会用manpage的.

FIFO非阻塞读打开是可以在无任何写端的情况下成功返回, 但FIFO非阻塞写打开不能在无任何读端的情况下成功.

你这里父子进程明显是执行顺序不一致的, 谁先谁后导致你说的有时好用有时不好用.

106033177

回复 1# qqrilxk
sorry  查了一下linux下允许读写打开。为了验证是否是由于没有读端导致的子进程写打开失败，是否可以在父进程先读打开？
...
os.mkfifo(pipe)
fd = os.open('testpipe',os.O_NONBLOCK|os.O_RD)
p = multiprocessing.Process( target=writefifo, args=() )
p.start()
....

但是 linux下读写打开是没有打开顺序的影响的。
Under Linux, opening a FIFO for read and write will succeed both in blocking and non-blocking mode. POSIX leaves this behaviour undefined. This can be used to open a FIFO for writing while there are no readers available.