python-连续读取命名管道

在Python中连续读取命名管道的最佳方法是什么？

这是我当前的代码：

def read_commands():
    try:
        print "Creating read pipe..."
        os.mkfifo(pipe_cmd)    # Create pipe
        print "Pipe created!"
    except:
        print "Pipe already exists"

    with open(pipe_cmd, "r") as pipecmd:
        while True:
            try:
                line = pipecmd.readline()
            except:
                print "Could not read cmd pipe"

            if line != "":
                print line

        #time.sleep(1)

但是,当我运行此代码时,似乎从我的CPU中占用了很多资源(其中一个资源将达到100％). 1秒钟的睡眠可以正常工作.但是,我需要连续读取管道以确保是否有新数据.有没有更好的方法可以做到这一点？

这就是我要发送到C中的管道的内容：

void write_pipe(){
    ofstream pipe("/tmp/okccmd");  // Open the pipe
    string data = "Hi";
    pipe << data << endl;
    pipe.flush();
}

谢谢！

解决方法:

select.poll可以正常工作(至少对于Linux而言,不确定Windows是否支持；但是select.select ist afaik可用).只需看一下文档,该模块就在标准库中并且有充分的文档记录(无需知道OS select()函数的实际工作方式).

说明文件：
https://docs.python.org/3/library/select.html

注意：poll()返回文件描述符列表,而不是文件对象列表.因此,您应该有一个dict将文件描述符映射到相应的对象(如果我只轮询一个文件,我也会有一个dict.

pollobj = select.poll()
polled_files = dict()

# the following two lines are reuired for every file
pollobj.register(my_file_obj, <EVENTMASK>)
polled_files[my_file_obj.fileno()] = my_file_obj

for fd, evt in pollobj.poll():
    fileobj = polled_files[fd]
    ... process event for fileobj

标签：fifo,named-pipes,python
来源： https://codeday.me/bug/20191120/2044240.html