博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
多任务-进程之Queue的进程间通信
阅读量:6076 次
发布时间:2019-06-20

本文共 1526 字,大约阅读时间需要 5 分钟。

1.经过线程和进程的对比,不难的知道,线程和进程有相当大的区别,如全局变量资源不能够共享。

2.在不同的进程间,如何实现通信呢?

 需要提及的一个概念就是Queue,它是一个消息队列,下面通过一个例子来更好的解释这个功能

#coding=utf-8from multiprocessing import Queueq=Queue(3) #初始化一个Queue对象,最多可接收三条put消息q.put("消息1") q.put("消息2")print(q.full())  #Falseq.put("消息3")print(q.full()) #True#因为消息列队已满下面的try都会抛出异常,第一个try会等待2秒后再抛出异常,第二个Try会立刻抛出异常try:    q.put("消息4",True,2)except:    print("消息列队已满,现有消息数量:%s"%q.qsize())try:    q.put_nowait("消息4")except:    print("消息列队已满,现有消息数量:%s"%q.qsize())#推荐的方式,先判断消息列队是否已满,再写入if not q.full():    q.put_nowait("消息4")#读取消息时,先判断消息列队是否为空,再读取if not q.empty():    for i in range(q.qsize()):        print(q.get_nowait())

3.初始化Queue()对象时(例如:q=Queue()),若括号中没有指定最大可接收的消息数量,或数量为负值,那么就代表可接受的消息数量没有上限(直到内存的尽头);

4.Queue的一些语句

  • Queue.qsize():返回当前队列包含的消息数量;

  • Queue.empty():如果队列为空,返回True,反之False ;

  • Queue.full():如果队列满了,返回True,反之False;

  • Queue.get([block[, timeout]]):获取队列中的一条消息,然后将其从列队中移除,block默认值为True;

  1)如果block使用默认值,且没有设置timeout(单位秒),消息列队如果为空,此时程序将被阻塞(停在读取状态),直到从消息列队读到消息为止,如果设置了timeout,则会等待timeout秒,若还没读取到任何消息,则抛出"Queue.Empty"异常;

  2)如果block值为False,消息列队如果为空,则会立刻抛出"Queue.Empty"异常;

     Queue.get_nowait():相当Queue.get(False);

     Queue.put(item,[block[, timeout]]):将item消息写入队列,block默认值为True; 

        1)如果block使用默认值,且没有设置timeout(单位秒),消息列队如果已经没

        有空间可写入,此时程序将被阻塞(停在写入状态),直到从消息列队腾出空间为止,

        如果设置了timeout,则会等待timeout秒,若还没空间,则抛出"Queue.Full"异常;

        2)如果block值为False,消息列队如果没有空间可写入,则会立刻抛出"Queue.Full"异常;

             Queue.put_nowait(item):相当Queue.put(item, False);

 

转载于:https://www.cnblogs.com/zxh1297/p/9364045.html

你可能感兴趣的文章
iOS开发流程总结
查看>>
hadoop datanode 启动出错
查看>>
js颜色拾取器
查看>>
IDEA使用(1)intellIJ idea 配置 svn
查看>>
WPF 降低.net framework到4.0
查看>>
数据管理DMS 全量SQL诊断:你的SQL是健康的蓝色,还是危险的红色?
查看>>
搭建一个通用的脚手架
查看>>
开年巨制!千人千面回放技术让你“看到”Flutter用户侧问题
查看>>
开源磁盘加密软件VeraCrypt教程
查看>>
本地vs云:大数据厮杀的最终幸存者会是谁?
查看>>
阿里云公共镜像、自定义镜像、共享镜像和镜像市场的区别 ...
查看>>
shadowtunnel v1.7 发布:新增上级负载均衡支持独立密码
查看>>
Java线程:什么是线程
查看>>
mysql5.7 创建一个超级管理员
查看>>
【框架整合】Maven-SpringMVC3.X+Spring3.X+MyBatis3-日志、JSON解析、表关联查询等均已配置好...
查看>>
要想成为高级Java程序员需要具备哪些知识呢?
查看>>
带着问题去学习--Nginx配置解析(一)
查看>>
onix-文件系统
查看>>
java.io.Serializable浅析
查看>>
我的友情链接
查看>>