[已解决]queue.Queue类的一个小问题

介左来了

1. import queue
   
2. import threading
   
3. import time
   
4. 
   
5. exitFlag = 0
   
6. 
   
7. class myThread (threading.Thread):
   
8.     def __init__(self, threadID, name, q):
   
9.         threading.Thread.__init__(self)
   
10.         self.threadID = threadID
    
11.         self.name = name
    
12.         self.q = q
    
13.     def run(self):
    
14.         print ("开启线程：" + self.name)
    
15.         process_data(self.name, self.q)
    
16.         print ("退出线程：" + self.name)
    
17. 
    
18. def process_data(threadName, q):
    
19.     while not exitFlag:
    
20.         queueLock.acquire()
    
21.         if not workQueue.empty():
    
22.             data = q.get()
    
23.             queueLock.release()
    
24.             print ("%s processing %s" % (threadName, data))
    
25.         else:
    
26.             queueLock.release()
    
27.         time.sleep(1)
    
28. 
    
29. threadList = ["Thread-1", "Thread-2", "Thread-3"]
    
30. nameList = ["One", "Two", "Three", "Four", "Five"]
    
31. queueLock = threading.Lock()
    
32. workQueue = queue.Queue(10)
    
33. threads = []
    
34. threadID = 1
    
35. 
    
36. # 创建新线程
    
37. for tName in threadList:
    
38.     thread = myThread(threadID, tName, workQueue)
    
39.     thread.start()
    
40.     threads.append(thread)
    
41.     threadID += 1
    
42. 
    
43. # 填充队列
    
44. queueLock.acquire()
    
45. for word in nameList:
    
46.     workQueue.put(word)
    
47. queueLock.release()
    
48. 
    
49. # 等待队列清空
    
50. while not workQueue.empty():
    
51.     pass
    
52. 
    
53. # 通知线程是时候退出
    
54. exitFlag = 1
    
55. 
    
56. # 等待所有线程完成
    
57. for t in threads:
    
58.     t.join()
    
59. print ("退出主线程")

复制代码

其中，等待队列清空的while语句，这样的写法，如果队列为空，岂不是死循环了吗，不理解这样的写法，希望大神可以解惑。

最佳答案

月排行榜 / 总排行榜

Stubborn

2020-1-8 23:41:36

介左来了 发表于 2020-1-8 22:37
按照我的理解，对于队列只有get() 和 put()两个方法才会增加队列中的内容

当程序执行到此处时，while ...

肯定啊，啥是多线程？？ 你以为程序堵塞在这里，其他的不运行了？其他线程肯定在消耗队列任务呀

跳转到最佳答案楼层

Stubborn

1. # 等待队列清空
   
2. while not workQueue.empty():
   
3.     pass

复制代码

队列为空，这里就过了，有任务才堵塞在这里，别搞反了。   empty  这个函数在起作用，没有任务才返回True

介左来了

Stubborn 发表于 2020-1-8 02:54
队列为空，这里就过了，有任务才堵塞在这里，别搞反了。   empty  这个函数在起作用，没有任务才返回Tr ...

写的时候没注意，如果队列非空时，是不是一直卡在这边？

Stubborn

介左来了 发表于 2020-1-8 06:40
写的时候没注意，如果队列非空时，是不是一直卡在这边？

肯定拉，不卡这里就退出任务了

介左来了

Stubborn 发表于 2020-1-8 16:07
肯定拉，不卡这里就退出任务了

所以我就比较不理解，如果语句执行到这边时非空，那岂不是程序到这边永远都跳不出while循环了吗？此处的意义是什么啊

Stubborn

介左来了 发表于 2020-1-8 20:58
所以我就比较不理解，如果语句执行到这边时非空，那岂不是程序到这边永远都跳不出while循环了吗？此处的 ...

目的就是堵塞啊，让队列的任务执行完在退出呀~不然 程序就退出

想不通吗？有任务堵塞，程序不退出，没任务不堵塞，过这里，然后就结束线程了

介左来了

Stubborn 发表于 2020-1-8 21:00
目的就是堵塞啊，让队列的任务执行完在退出呀~不然 程序就退出

想不通吗？有任务堵塞，程序不退出， ...

按照我的理解，对于队列只有get() 和 put()两个方法才会增加队列中的内容

1. # 等待队列清空
   
2. while not workQueue.empty():
   
3.     pass

复制代码

当程序执行到此处时，while语句体是pass，加入队列是非空状态，语句体中又没有get()方法，那岂不是语句体一直处于非空状态，程序执行到此处时就陷入了无限循环中？

写到此处，突然意识到，while语句执行的同时，多个线程同时也在对队列中的内容进行get()吧，所以队列空了之后，while后面的标志位才会翻转，这样理解对吧。

Stubborn

介左来了 发表于 2020-1-8 22:37
按照我的理解，对于队列只有get() 和 put()两个方法才会增加队列中的内容

当程序执行到此处时，while ...

肯定啊，啥是多线程？？ 你以为程序堵塞在这里，其他的不运行了？其他线程肯定在消耗队列任务呀

介左来了

谢谢，理解了