如何在Python Tornado websocket中创建非阻塞while循环来流式传输数据

import tornado.ioloop
import tornado.web
import tornado.websocket

class WebSocketHandler(tornado.websocket.WebSocketHandler):
    def open(self):
        self.write_message("WebSocket connection established.")

        # 在这里启动非阻塞的while循环
        self.non_blocking_loop()

    def non_blocking_loop(self):
        # 在这里执行非阻塞的操作，例如从数据库或其他数据源获取数据
        data = self.get_data()

        if data:
            self.write_message(data)

        # 使用Tornado的IOLoop的add_callback方法来实现非阻塞循环
        tornado.ioloop.IOLoop.current().add_callback(self.non_blocking_loop)

    def get_data(self):
        # 从数据源获取数据的逻辑
        # 返回需要传输的数据，如果没有数据则返回None
        pass

    def on_message(self, message):
        # 处理客户端发送的消息
        pass

    def on_close(self):
        # WebSocket连接关闭时的处理逻辑
        pass

app = tornado.web.Application([
    (r"/websocket", WebSocketHandler),
])

if __name__ == "__main__":
    app.listen(8888)
    tornado.ioloop.IOLoop.current().start()