什么是在Python中连续读取命名管道的最佳方式?
以下是我的当前代码:
然而,当我运行此代码时,它似乎从我的CPU中占用了很多资源(其中一个将达到100%)。使用1秒的延迟可以正常工作。但是,我需要持续读取管道以确保是否有新数据。有更好的方法来完成这个吗?
以下是我在C ++中发送到管道的内容:
以下是我的当前代码:
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
模块。 - wim