Python上的非阻塞生成器

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了Python上的非阻塞生成器，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含823字，纯文字阅读大概需要2分钟。

内容图文

我正在使用QT应用程序中的请求模块中的生成器功能,与请求流示例中的几乎相同：

import json
import requests

def get_stream():
    r = requests.get('http://httpbin.org/stream/20', stream=True)
    for line in r.iter_lines():
        if line:
            yield json.loads(line)

def consume_stream():
    for message in get_stream():
       #do something

但是,如果没有传入响应(例如来自Twitters Streaming API的不定期传入推文),则生成器get_stream将阻止consumpt_stream方法.

在任何情况下,生成器都不会立即让步,而是必须等待传入的消息等,从而阻塞了使用者,这可能会发生.

Python中是否有任何模式可以让您以非阻塞方式使用生成器,即,如果生成器屈服,则处理其结果,否则进行其他操作直到出现下一个结果？

解决方法:

看一下producer-consumer pattern.通常在Python中使用Queue来实现.

生产者通常在线程或其他进程中运行(队列支持其中一种),只是将消息放入队列中.消费者只要有感觉,就会从队列中弹出消息.此操作支持超时参数.

内容总结

以上是互联网集市为您收集整理的Python上的非阻塞生成器全部内容，希望文章能够帮你解决Python上的非阻塞生成器所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端