python 继承线程的类 不能通过标志位结束线程
本文介绍了python 继承线程的类 不能通过标志位结束线程的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
问 题
在测试生产消费者模型的时候遇到这样一个问题,在继承线程后 加了个标志位 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()
完全没有退出。
请教下,这是什么原因?
解决方案
class Consumer(threading.Thread):
def __init__(self, queue):
threading.Thread.__init__(self)
self._queue = queue
self.mark = True
def run(self):
while self.mark:
try:
msg = self._queue.get(block=False) # 非阻塞
print("I'm a thread, and I received %s!!" % msg)
except:pass
print('self.mark',self.mark)
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 = False
worker.join()
这篇关于python 继承线程的类 不能通过标志位结束线程的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文