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

Question

我在研究以下 website.

中的线程和队列时构建了以下代码

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

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

Producer-Consumer algorithm in python

python

multithreading

producer-consumer

python-3.4