如何结束另一个线程中的While循环?
问题描述
我想结束在另一个线程中的while True
循环:
from time import sleep
from threading import Thread
condition = False
def check_sth():
while True:
if condition:
print("Condition met, ending")
break
else:
sleep(0.25)
do_sth() # Do something everytime the condition is not met
Thread(target=check_sth(), args=(,)).start()
sleep(2)
condition = False
# Doesn't print "Condition met..."
或者有什么方法可以简单地kill
创建线程,这样我就可以执行以下操作:
thread = Thread(target=check_sth(), args=(,))
thread.start()
thread.kill() # (?)
也欢迎使用asyncio
或其他框架执行此操作的方法。
解决方案
注意,您的代码在创建Thread
时没有正确传递参数,并且不要将condition
布尔变量设置为True
。
下面是如何修复和能够停止另一个线程中的while
循环的方法。它不是简单的布尔变量,而是使用Threading.Event
对象来控制循环,并允许从主线程以线程安全的方式将其设置为真。
代码
from time import sleep
from threading import Event, Thread
condition = Event()
def do_sth():
print("truckin' ...")
def check_sth():
while not condition.is_set():
sleep(0.25)
do_sth() # Do something everytime the condition is not set.
print("Condition met, ending.")
Thread(target=check_sth, args=()).start()
sleep(2)
condition.set() # End while loop.
输出
truckin' ...
truckin' ...
truckin' ...
truckin' ...
truckin' ...
truckin' ...
truckin' ...
truckin' ...
Condition met, ending.
相关文章