zoukankan      html  css  js  c++  java
  • python 进程 Queue

     1 """
     2 队列
     3 q = Queue(5)  # 创建一个最大容量为5的队列,先进先出的原则
     4 q.put("1") # 添加元素,队列数量满了的时候,会堵在put处
     5 q.put("1", timeout=3)  # 如果超出3秒没有加入进去就会报错
     6 q.put_nowait("6")  # 不等,如果满了,直接报错
     7 q.full()  # 如果队列已满就返回True
     8 
     9 q.get()  # 先进先出的原则取出元素,没有元素将堵塞在这
    10 q.get(timeout=3)  # 如果超出3秒没有获取到就会报错
    11 q.get_nowait() # 不等,如果空了,直接报错
    12 q.empty()  # 是否是空
    13 
    14 q.join()  # 阻塞
    15 """
    16 
    17 from multiprocessing import Queue
    18 
    19 q = Queue(5)  # 创建一个最大容量为5的队列
    20 q.put("1", timeout=3)
    21 q.put("2")
    22 q.put("3")
    23 q.join()
    24 q.put("4")
    25 q.put("5")
    26 print(q.qsize())
    27 q.close()
    28 q.get()
    29 q.get()
    30 q.get()
    31 q.get()
    32 q.get()
    33 q.get_nowait()
    34 
    35 
    36 
    37 print("over")
  • 相关阅读:
    webServer xampp的安装及使用
    javascript 原生方法监听DOM结构改变事件
    c# 文件简繁体转换
    c# 网络是否连接
    JMS
    JMS
    JMS
    Quartz Scheduler(2.2.1)
    MySQL
    Git CMD
  • 原文地址:https://www.cnblogs.com/cfpl/p/12991993.html
Copyright © 2011-2022 走看看