zoukankan      html  css  js  c++  java
  • 7.2.6

    队列介绍

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

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

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

    参数介绍:

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

    主要方法介绍:

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

    from multiprocessing import Queue
    q = Queue(3)      # 队列最大长度为3
    q.put("hello")
    q.put({'a':1})
    q.put([1,2,3])
    # q.put(1)        #  在放就阻塞了,因为队列已经满了
    print(q.full())   # 查看队列是否满了(满了就True)
    for i in range(3):
        print(q.get())
    print(q.empty())  # 查看队列是否空了(空了就True)
    print(q.empty())  # 在取就阻塞了因为,队列没有数据,所以就阻塞
     
  • 相关阅读:
    android日期处理工具类
    android图片处理工具类
    android动画工具类
    android之Toast工具类
    android日志工具类
    androidApp开发之“BMI指数计算”
    android游戏开发之“找出红心A”
    android之获取联系人并按拼音排序
    android之音乐播放和音效播放
    .net学习路线
  • 原文地址:https://www.cnblogs.com/caimengzhi/p/8511725.html
Copyright © 2011-2022 走看看