前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >并发篇-python并发通信-3

并发篇-python并发通信-3

作者头像
小团子
发布2019-07-18 10:59:19
8430
发布2019-07-18 10:59:19
举报
文章被收录于专栏:数据云团数据云团
  • .qsize() 返回队列的大小
  • .empty() 如果队列为空,返回True,反之False
  • .full() 如果队列满了,返回True,反之False
  • .full 与 maxsize 大小对应
  • .get([block[, timeout]])获取队列,timeout等待时间
  • .get_nowait() 相当Queue.get(False)
  • .put(item) 写入队列,timeout等待时间
  • .put_nowait(item) 相当Queue.put(item, False)
  • .task_done() 在完成一项工作之后,Queue.task_done()函数向任务已经完成的队列发送一个信号
  • .join() 实际上意味着等到队列为空,再执行别的操作。

消费者与生产者模型

生产者与消费者模型,

其实是把一个需要进程通信的问题分开考虑

生产者,只需要往队列里面丢东西(生产者不需要关心消费者)

消费者,只需要从队列里面拿东西(消费者也不需要关心生产者)

Web服务器与Web框架之间的关系

多线程的消费者与生产者模型

# 声明队列

>>> q = queue.Queue(maxsize=10)

# 往队列中添加数据

>>> q.put(item)

# 从队列中取数据

>>> item = q.get()

生产者:只关心队列是否已满。没满,则生产,满了就阻塞。

消费者:只关心队列是否为空。不为空,则消费,为空则阻塞。

本文参与 腾讯云自媒体分享计划,分享自微信公众号。
原始发表:2018-12-23,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 数据云团 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档