python中的生产者-消费者算法

Question

我在学习以下网站上的线程和队列时构建了以下代码。

from __future__ import print_function
import queue
import threading
import time
class a3_4(threading.Thread):
    q = queue.Queue()
    def __init__(self, begin, end, waiting_time):
        self.begin = begin
        self.end = end
        self.waiting_time = waiting_time
        threading.Thread.__init__(self)
    def run(self):
        while True:
            if self.begin != self.end:
                self.q.put(self.begin)
                self.begin += 1
                time.sleep(5)
            else:
                break
    def op(self):
        self.start()
        while True:
            if not self.q.empty():
                print("Outputting: ", self.q.get())
            time.sleep(self.waiting_time)
if __name__ == '__main__':
    myThread = a3_4(1, 5, 1)
    myThread.op()

我得到以下输出：

python3 a3_4.py 
Outputting:  1
Outputting:  2
Outputting:  3
Outputting:  4

但这个项目并没有自行停止。我试着插入else: break，但这只给了我Outputting: 1我是不是错过了一些基本的东西？

Answer 1

我认为，您正在模拟生产者-消费者问题。问题是生产者线程正常停止，但消费者线程（主线程）没有终止子句。所以我认为您需要为消费者方法op（）添加一些终止子句。

可能是：

def op(self):
        self.start()
        while True:
            time.sleep(self.waiting_time)
            if not self.q.empty():
                print("Outputting: ", self.q.get())
            else:
                break