TornadoノンブロッキングWebSocketサーバー実装

Question

class Client(tornado.websocket.WebSocketHandler): 
    def open(self): 
     print "Connection is opened" 

    def on_message(self, message): 
     self.Process(message) 

    def on_close(self): 
     print "socket closed" 

上記のコードはpython/tornadoであると仮定します。 Clientのインスタンスは、新しいWebSocketクライアントがサーバーに接続するときに作成されます。問題は、self.process(message)が処理中であり、ハンドラ全体がブロックされている（接続を受け付けず、メッセージを受信しない）ということです。self.process(message)が処理中である限りです。この障害を克服するための解決策はありますか？

Answer 1

は、ここではThreadPoolExecutorを始めるための基本的なコードです：

import concurrent.futures 

# create a `ThreadPoolExecutor` instance 
executor = concurrent.futures.ThreadPoolExecutor(max_workers=8) 


class Client(tornado.websocket.WebSocketHandler): 

    def on_message(self, message): 
     # ask `executor` to run `self.process` in a thread 
     executor.submit(self.process, message) 

    def process(self, message): 
     # do something blocking ... 
     return processed_message 

---

あなたがそれを処理した後on_message内のメッセージにアクセスしたい場合、あなたはその後、gen.coroutineし、それを飾るためにしましたyieldexecutor.submit(...)：

from tornado import gen 

class Client(tornado.websocket.WebSocketHandler): 

    # decorate on_message with gen.coroutine 
    @gen.coroutine 
    def on_message(self, message): 
     # now use the yield keyword 
     processed_message = yield executor.submit(self.process, message) 
     # do something with processed_message 

    def process(self, message): 
     # do something blocking ... 
     return processed_message