Python 3的selectors模块提供了一个通用接口来使用各种I/O多路复用技术,例如select、poll、epoll和kqueue。这使得你可以编写跨平台的代码,而不需要担心每个操作系统特有的底层技术细节。
以下是一个使用selectors模块的基本例子,它使用了Selector
类来监听标准输入(stdin)上的读事件,并在有输入时打印出来。
import sys
import selectors
import types
# 创建一个Selector对象
sel = selectors.DefaultSelector()
def accept(key, mask):
# 这里是当有可读事件时被调用的回调函数
print("Event received!")
# 注册标准输入文件描述符来监听读事件
sel.register(sys.stdin.fileno(), selectors.EVENT_READ, accept)
while True:
# 等待注册的事件发生,block=True会阻塞等待,None表示无超时
events = sel.select(block=True)
for key, mask in events:
callback = key.data
if isinstance(callback, types.CoroutineType):
# 如果回调是一个协程对象,需要通过ensure_future在事件循环中运行它
selectors.loop.create_task(callback(key, mask))
else:
# 否则直接调用回调函数
callback(key, mask)
这个例子展示了如何使用selectors模块创建一个简单的事件循环,它会在有输入可读时触发事件并调用回调函数。注意,在实际应用中,你可能需要根据实际的网络编程场景来编写更复杂的回调函数和事件处理逻辑。