标签：RoCE inter 设置 int 删掉 优先 取数据 list task
queue
队列！特点是有序的,跟list的区别，list调用元素，其实就是复制，还要用remove给删掉，麻烦，queue更加方便
生成队列的方法：
class queue.Queue(maxsize=0) #先入先出 #maxsize可以设定队列大小
class queue.LifoQueue(maxsize=0) #last in fisrt out 后进先出，例如卖东西，大家都喜欢新鲜的
class queue.PriorityQueue(maxsize=0) #存储数据时可设置优先级的队列
#PriorityQueue VIP！！ #例子 import queue q=queue.PriorityQueue() q.put((18,‘qiangql‘)) q.put((2,‘egbert‘)) q.put((39,‘boboka‘)) print(q.get( )) print(q.get( )) print(q.get( )) #运行结果 (2, ‘egbert‘) (18, ‘qiangql‘) (39, ‘boboka‘)
基本语法：
存数据
Queue.put（）
取数据
Queue.get（block=True, timeout=None） #block 堵塞，默认是Ture，娶不到数据卡主，timeout等待时间，最多等多久
判断队列大小 #当前队列大小
Queue.qsize（）
设置队列大小
Queue（maxsize=99）
验证队列是否为空，返回真，假
Queue.empty（）
Queue.task_done（） #还没看一会补充
Indicate that a formerly enqueued task is complete. Used by queue consumer threads. For each get() used to fetch a task, a subsequent call to task_done() tells the queue that the processing on the task is complete.
If a join() is currently blocking, it will resume when all items have been processed (meaning that a task_done() call was received for every item that had been put() into the queue).
Raises a ValueError if called more times than there were items placed in the queue.
例子1:
import threading,time import queue def producer(): count=1 while True: q.put(‘骨头%s‘%count) print(‘生产骨头%s‘%count) count+=1 time.sleep(0.5) def consumer(name): while True: print("%s 取到%s" %(name, q.get())) time.sleep(1.5) q = queue.Queue(maxsize=10) p = threading.Thread(target=producer, ) p.start() c1 = threading.Thread(target=consumer,args=(‘qianglq‘,)) c2 = threading.Thread(target=consumer,args=(‘buring‘,)) c1.start() c2.start()
执行结果：
生产骨头1
qianglq 取到骨头1
生产骨头2
buring 取到骨头2
生产骨头3
生产骨头4
qianglq 取到骨头3
buring 取到骨头4
生产骨头5
生产骨头6
生产骨头7
qianglq 取到骨头5
生产骨头8
buring 取到骨头6
生产骨头9
生产骨头10
例子2
import threading import queue def producer(): for i in range(10): q.put("骨头 %s" % i) print("开始等待所有的骨头被取走...") q.join() print("所有的骨头被取完了...") def consumer(n): while q.qsize() > 0: print("%s 取到" % n, q.get()) q.task_done() # 告知这个任务执行完了 q = queue.Queue() p = threading.Thread(target=producer, ) p.start() c1 = consumer("43轮") 执行结果： 开始等待所有的骨头被取走... 43轮 取到 骨头 0 43轮 取到 骨头 1 43轮 取到 骨头 2 43轮 取到 骨头 3 43轮 取到 骨头 4 43轮 取到 骨头 5 43轮 取到 骨头 6 43轮 取到 骨头 7 43轮 取到 骨头 8 43轮 取到 骨头 9 所有的骨头被取完了...
标签：RoCE inter 设置 int 删掉 优先 取数据 list task
原文地址：https://www.cnblogs.com/PYlog/p/9241142.html
