首页 / PYTHON / python-连续读取命名管道
python-连续读取命名管道
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了python-连续读取命名管道,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含1365字,纯文字阅读大概需要2分钟。
内容图文
![python-连续读取命名管道](/upload/InfoBanner/zyjiaocheng/662/77dcdf5990b6498d942a0558baa38ab2.jpg)
在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
内容总结
以上是互联网集市为您收集整理的python-连续读取命名管道全部内容,希望文章能够帮你解决python-连续读取命名管道所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。