码迷,mamicode.com
首页 > 编程语言 > 详细

python并发编程:多进程-队列

时间:2018-07-08 10:43:27      阅读:173      评论:0      收藏:0      [点我收藏+]

标签:pytho   内存   多进程   两种   family   进程安全   imp   empty   进程间通信   

队列介绍

  进程彼此之间互相隔离,要实现进程间通信(IPC),multiprocessing模块支持两种形式:队列和管道,这两种方式都是使用消息传递的

创建队列的类(底层就是以管道和锁定的方式实现)

Queue(maxsize):创建共享的进程队列,Queue是多进程安全的队列,可以使用Queue实现多进程之间的数据传递

  参数介绍

maxsize是队列中允许最大项数,省略则无大小限制
但需要明确:
    1、队列内存放的是消息而非大数据
    2、队列占用的是内存空间,因而maxsize即便是无大小限制也受限于内存大小

  主要方法介绍

q.put方法用以插入数据到队列中
q.get方法可以从队列读取并且删除一个元素

  队列的使用

from multiprocessing import Queue

q = Queue(3)

q.put(1)
q.put(2)
q.put(3)
print(q.full())     # 满了
# q.put(4)  # 再放就阻塞住了

print(q.get())
print(q.get())
print(q.get())
print(q.empty())    # 空了
print(q.get())  # 再取就阻塞住了

  

python并发编程:多进程-队列

标签:pytho   内存   多进程   两种   family   进程安全   imp   empty   进程间通信   

原文地址:https://www.cnblogs.com/mike-liu/p/9279182.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!