以下是一个简单的示例，演示如何在 Tornado 中使用协程队列：
import tornado.ioloop
import tornado.web
from tornado.queues import Queue
# 创建一个协程队列
message_queue = Queue(maxsize=10)
class ProducerHandler(tornado.web.RequestHandler):
async def get(self, message):
global message_queue
# 向队列中放入消息
await message_queue.put(message)
self.write("Message '{}' added to the queue.".format(message))
class ConsumerHandler(tornado.web.RequestHandler):
async def get(self):
global message_queue
try:
# 从队列中获取消息
message = await message_queue.get(timeout=5)
self.write("Message '{}' retrieved from the queue.".format(message))
except tornado.gen.TimeoutError:
self.write("Timeout: No message available in the queue.")
def make_app():
return tornado.web.Application([
(r"/produce/(\w+)", ProducerHandler),
(r"/consume", ConsumerHandler),
])
if __name__ == "__main__":
app = make_app()
app.listen(8888)
tornado.ioloop.IOLoop.current().start()
在这个示例中，Queue 被用于在生产者和消费者之间传递消息。生产者通过访问 ProducerHandler 的 get 方法将消息放入队列，而消费者通过访问 ConsumerHandler 的 get 方法从队列中取出消息。在实际应用中，可以根据需求创建多个生产者和消费者协程。
请注意，Queue 的 get 方法支持设置超时时间，以防止在队列为空时无限等待。上述示例中，设置了 5 秒的超时时间，如果在这个时间内队列仍然为空，则会抛出 tornado.gen.TimeoutError 异常。
这样，通过协程队列，可以安全地在 Tornado 应用程序中进行协程间的通信。
转载请注明出处：http://www.zyzy.cn/article/detail/7443/Tornado