玩蛇网提供最新Python编程技术信息以及Python资源下载!
您现在的位置: 玩蛇网首页 > Python问题解答 > 正文内容

python tornado异步方式仍然有阻塞

代码大致如下

@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 # 阻塞

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

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

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

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

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

玩蛇网文章,转载请注明出处和文章网址:http://www.iplaypy.com/wenda/wd14201.html

相关文章 Recommend

玩蛇网Python互助QQ群,欢迎加入-->: 106381465 玩蛇网Python新手群
修订日期:2018年01月13日 - 09时15分03秒 发布自玩蛇网

我要分享到:

必知PYTHON教程 Must Know PYTHON Tutorials

必知PYTHON模块 Must Know PYTHON Modules