python中生产者消费者线程问题

Question

在使用python的多线程时，使用了生产者消费者模式，一般都是消费者接受生产者的数据执行某些操作，但是现在这个消费者线程遇到了异常，需要终止执行，但是生产者线程因为还在生产数据，主线程在等待它执行完。目前想当消费者线程遇到错误时能够通知生产者线程，我挂了，你也结束吧。请问大家有什么好的实现方法

import threading

class Producer(threading.Thread):

    def __init__(self, queue):
        super(Producer, self).__init__()
        self.queue = queue

    def run(self):
        while True:
            for i in range(10):
                self.queue.put(i)

class Consumer(threading.Thread):

    def __init__(self, queue):
        super(Consumer, self).__init__()
        self.queue = queue

    def run(self):
        while True:
            try:
                data = self.queue.get()
                print data
                if data == 5:
                    raise ValueError('over')
            except ValueError as e:
                #通知生产者结束
                #如何实现？
            

Answer 1

私の方法:
旗のロゴを追加します。

まず結果を見てみましょう:

これ以上ナンセンスはやめて、コードを見せてください

リーリー

最後に、Python のマルチスレッドについて話しましょう。GIL の存在により、マルチスレッドが最適な選択ではない場合があります。作成者は、それを使用することもできます。彼自身のビジネス状況に基づいてスレッドモジュールを作成します。

Answer 2

簡単に言えば、エラーを発生させてプロセスを自動的にクラッシュさせるだけです。
または、例外処理を使用してコンシューマの実行をラップし、例外をキャッチして、プロデューサのスレッドを制御することもできます。