python 继承线程的类 不能通过标志位结束线程
黄舟
黄舟 2017-05-18 11:02:22
0
1
824

在测试生产消费者模型的时候遇到这样一个问题,在继承线程后 加了个标志位 mark

class Consumer(threading.Thread):
    def __init__(self, queue):
        threading.Thread.__init__(self)
        self._queue = queue
        self.mark = True

    def run(self):
        while self.mark:
            msg = self._queue.get()
            if isinstance(msg, str) and msg == 'quit':
                break
            print("I'm a thread, and I received %s!!" % msg)

        print('Bye byes!')
def producer():
    q = queue.Queue()
    worker = Consumer(q)
    worker.start()  # 开启消费者线程
    start_time = time.time()
    while time.time() - start_time < 5:
        q.put('something at %s' % time.time())
        time.sleep(1)
    worker.mark = Flese
    worker.join()

我原先指望 通过这个标志位来实现线程的结束控制,但实际效果是程序卡死在worker.join()
完全没有退出。

请教下,这是什么原因?

黄舟
黄舟

人生最曼妙的风景,竟是内心的淡定与从容!

全部回复(1)
伊谢尔伦

雷雷

热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板