2回答

bobby

2019-08-01

import time
from tornado.concurrent import run_on_executor
from concurrent.futures import ThreadPoolExecutor   
MAX_WORKERS = 4
class Handler(tornado.web.RequestHandler):
    executor = ThreadPoolExecutor(max_workers=MAX_WORKERS)    
    @run_on_executor
    def background_task(self, i):        """ This will be executed in `executor` pool. """
        time.sleep(10)        
        return i    
        
    @tornado.gen.coroutine
    def get(self, idx):        """ Request that asynchronously calls background task. """
        res = yield self.background_task(idx)        
        self.write(res)

0

2

bobby

回复

微微视界123

能否将代码格式化一下 你不要在回复中写，你直接在评论中回复就可以格式化了

2019-08-05

共2条回复

bobby

2019-07-31

tornado启动的时候有线程池 https://gist.github.com/methane/2185380 可以参照这个将阻塞任务扔到线程池中去运行

0

1

微微视界123

老师，这个地址打不开啊

2019-08-01

共1条回复