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()