tornado异步方式仍然有阻塞

Question

代码大致如下

@gen.coroutine
def store_data(data):
   yield motor.insert_many(data)
   print motor.count()

class MainHandler(RequestHandler):
    @gen.coroutine
    def post(self):
        data = self.request.body
        IOLoop.current().spawn_callback(lambda: store_data(data))
        self.write("Task Done")
        self.finish()

然后写了个大致测试下，10个线程的requests.post，发现似乎仍然阻塞了

[I 161222 15:40:22 web:1971] 200 POST /upload/ (::1) 9.00ms
[I 161222 15:40:23 web:1971] 200 POST /upload/ (::1) 8.00ms
[I 161222 15:40:23 web:1971] 200 POST /upload/ (::1) 8.00ms
[I 161222 15:40:23 web:1971] 200 POST /upload/ (::1) 7.00ms
[I 161222 15:40:23 web:1971] 200 POST /upload/ (::1) 8.00ms
[I 161222 15:40:23 web:1971] 200 POST /upload/ (::1) 9.00ms
[I 161222 15:40:23 web:1971] 200 POST /upload/ (::1) 8.00ms
[I 161222 15:40:23 web:1971] 200 POST /upload/ (::1) 9.00ms
[I 161222 15:40:23 web:1971] 200 POST /upload/ (::1) 701.00ms # 这个请求似乎阻塞了
[I 161222 15:40:23 web:1971] 200 POST /upload/ (::1) 696.00ms # 阻塞

Answer 1

有些方法本身就会阻塞线程,比如你可以试试time.sleep

异步是相对于io操作来说的,当你在进行大量非io操作的时候,当然不能异步啦

Answer 2

@萝莉控吐槽勉 “异步是相对于io操作来说的,当你在进行大量非io操作的时候,当然不能异步”。说的比较到位。
我补充点愚见吧。
@morriaty_the_murderer 的业务操作是store_data函数，调用的是tornado的协程在做。tornado的协程本身是利用了yield生成器来实现的。当在生成器函数的一次next操作时，处理大量的计算型操作，肯定会阻塞到整个进程。
欢迎来讨论哈。

Answer 3

看代码感觉你应该是把文件通过tornado 上传然后以blob的形式储存到mingodb里面。

非常不建议这样操作，这个操作会导致多处大量内存拷贝，很容易导致阻塞