토네이도 비 차단 웹 소켓 서버 구현

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 시작 : 당신이 그것을 처리 한 후 on_message에서 메시지에 액세스하려는 경우

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 

---

, 당신은 gen.coroutine 다음 yield 함께 장식했습니다 : executor.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