标签：之间 wait maxsize 一个队列 exce 多少 方式 from get
1 import time 2 from multiprocessing import Queue 3 q = Queue(3) 4 q.put(1) 5 q.put(2) 6 print(‘----------‘,q.qsize()) # 2 7 q.put(3) 8 9 q.get() 10 q.get() 11 q.get() 12 print(q.empty()) # 队列已取完 True 13 14 q.put(4) # 又放了一个值 15 print(‘>>>>>‘,q.empty()) # 再次查看队列是否为空时，按理来说应该为False，但是打印的是True 原因：系统在向队列中次put值得时候会有及其细微的延迟 16 print(q.get())
1 from multiprocessing import Queue 2 q=Queue(3) #创建一个队列对象，队列长度为3 3 4 #put ,get ,put_nowait,get_nowait,full,empty 5 q.put(3) #往队列中添加数据 6 q.put(2) 7 q.put(1) 8 # q.put(4) # 如果队列已经满了，程序就会停在这里，等待数据被别人取走，再将数据放入队列。 9 # 如果队列中的数据一直不被取走，程序就会永远停在这里。 10 try: 11 q.put_nowait(4) # 可以使用put_nowait，如果队列满了不会阻塞，但是会因为队列满了而报错。 12 except: # 因此我们可以用一个try语句来处理这个错误。这样程序不会一直阻塞下去，但是会丢掉这个消息。 13 print(‘队列已经满了‘) 14 15 # 因此，我们再放入数据之前，可以先看一下队列的状态，如果已经满了，就不继续put了。 16 print(q.full()) #查看是否满了，满了返回True，不满返回False 17 18 print(q.get()) #取出数据 19 print(q.get()) 20 print(q.get()) 21 # print(q.get()) # 同put方法一样，如果队列已经空了，那么继续取就会出现阻塞。 22 try: 23 q.get_nowait(3) # 可以使用get_nowait，如果队列满了不会阻塞，但是会因为没取到值而报错。 24 except: # 因此我们可以用一个try语句来处理这个错误。这样程序不会一直阻塞下去。 25 print(‘队列已经空了‘) 26 27 print(q.empty()) #空了 28 29 队列的简单用法
1 import time 2 from multiprocessing import Process, Queue 3 4 def girl(q): 5 print(‘来自boy>>‘, q.get()) 6 print(‘来自主>>‘, q.get()) 7 8 def boy(q): 9 q.put(‘学吗‘) 10 11 if __name__ == ‘__main__‘: 12 13 q = Queue(5) 14 girl_p = Process(target=girl, args=(q,)) 15 boy_p = Process(target=boy, args=(q,)) 16 girl_p.start() 17 boy_p.start() 18 time.sleep(1) 19 q.put(‘好好学习‘)
标签：之间 wait maxsize 一个队列 exce 多少 方式 from get
原文地址：https://www.cnblogs.com/hq82/p/9851600.html
