zoukankan      html  css  js  c++  java
  • 队列(Quene)

    对multiprocessing中的Quene进行演示

     1 import multiprocessing
     2 """
     3 队列Quene是mutiprocessing 中 的一个类
     4 包括向队列中存数以及取数 等操作
     5 """
     6 quene = multiprocessing.Queue(4)
     7 quene.put(2)
     8 quene.put("hello")
     9 quene.put((1,2,3))
    10 quene.put({"a":10,"b":20})
    11 # 当向quene中存取数据超过quene的容量时,会对程序进行阻塞,此时使用put_nowait()进行存数时,会直接报错并终止程序。
    12 quene.put_nowait(656)
    13 value = quene.get()
    14 print(value)
    15 value = quene.get()
    16 print(value)
    17 value = quene.get()
    18 print(value)
    19 value = quene.get()
    20 print(value)
    21 # 当队列中的数据被取完时又执行get操作,会造成程序的阻塞,此时如果用get_nowait() 会直接终止程序的运行并报错
    22 # value = quene.get_nowait()
    23 print(value)
    
    
    
    
  • 相关阅读:
    HDU 4801 Pocket Cube
    HDU 5008 Boring String Problem(后缀数组+二分)
    2-Sat问题
    后缀数组
    树形DP
    图论
    SRM 628 DIV2
    组合博弈
    Github使用笔记
    VS2010+OpenCV配置
  • 原文地址:https://www.cnblogs.com/liuxjie/p/11984902.html
Copyright © 2011-2022 走看看