使用 PyZMQ 的 IOLoop 实例时,我遇到了奇怪的系统行为:
def main():
context = zmq.Context()
s = context.socket(zmq.REP)
s.bind('tcp://*:12345')
stream = zmqstream.ZMQStream(s)
stream.on_recv(on_message)
io_loop = ioloop.IOLoop.instance()
io_loop.add_handler(some_file.fileno(), on_file_data_ready_read_and_then_write, io_loop.READ)
io_loop.add_timeout(time.time() + 10, another_handler)
io_loop.start()
def on_file_data_ready_read_and_then_write(fd, events):
# Read content of the file and then write back
some_file.read()
print "Read content"
some_file.write("blah")
print "Wrote content"
def on_message(msg):
# Do something...
pass
if __name__=='__main__':
main()
基本上,事件循环监听 12345 的 zmq 端口以获取 JSON 请求,并在可用时从文件中读取内容(当它这样做时,对其进行操作并回写。基本上,该文件是一个特殊的 /proc/ 内核模块,已构建为了那个原因)。
一切正常,但由于某种原因,在查看 strace 时,我看到以下内容:
...
1. read(\23424) <--- Content read from file
2. write("read content")
3. write("Wrote content")
4. POLLING
5. write(\324324) # <---- THIS is the content that was sent using some_file.write()
...
所以看起来写入文件不是按照 python 脚本的顺序完成的,但是写入该文件的系统调用是在轮询之后完成的,即使它应该在第 2 行和第 3 行之间完成。
有任何想法吗?