告诉循环线程停止循环的正确方法是什么？

我有一个相当简单的程序，它在单独的 threading.Thread 类中 ping 指定的主机。在这个类中，它会休眠 60 秒，然后再次运行，直到应用程序退出。

我想在我的 wx.Frame 中实现一个“停止”按钮来要求循环线程停止。它不需要立即结束线程，它可以在唤醒后停止循环。

这是我的 threading 类(注意:我还没有实现循环，但它可能属于 PingAssets 中的 run 方法)

class PingAssets(threading.Thread):
    def __init__(self, threadNum, asset, window):
        threading.Thread.__init__(self)
        self.threadNum = threadNum
        self.window = window
        self.asset = asset

    def run(self):
        config = controller.getConfig()
        fmt = config['timefmt']
        start_time = datetime.now().strftime(fmt)
        try:
            if onlinecheck.check_status(self.asset):
                status = "online"
            else:
                status = "offline"
        except socket.gaierror:
            status = "an invalid asset tag."
        msg =("{}: {} is {}.   \n".format(start_time, self.asset, status))
        wx.CallAfter(self.window.Logger, msg)

在我的 wxPyhton 框架中，我从“开始”按钮调用了这个函数:

def CheckAsset(self, asset):
        self.count += 1
        thread = PingAssets(self.count, asset, self)
        self.threads.append(thread)
        thread.start()

最佳答案

线程可停止函数

不是继承 threading.Thread，而是可以修改函数以允许 停在一面旗帜。

我们需要一个对象，它可以被运行函数访问，我们将标志设置为停止运行。

我们可以使用 threading.currentThread() 对象。

import threading
import time


def doit(arg):
    t = threading.currentThread()
    while getattr(t, "do_run", True):
        print ("working on %s" % arg)
        time.sleep(1)
    print("Stopping as you wish.")


def main():
    t = threading.Thread(target=doit, args=("task",))
    t.start()
    time.sleep(5)
    t.do_run = False
    

if __name__ == "__main__":
    main()

诀窍在于，正在运行的线程可以附加其他属性。解决方案构建 关于假设:

• 线程有一个属性“do_run”，默认值为True
• 驱动父进程可以将属性“do_run”分配给启动线程False。

运行代码，我们得到以下输出:

$ python stopthread.py                                                        
working on task
working on task
working on task
working on task
working on task
Stopping as you wish.

Pill to kill - 使用事件

其他替代方法是使用 threading.Event 作为函数参数。它是由 默认 False，但外部进程可以“设置”(设置为 True)并且函数可以 使用 wait(timeout) 函数了解它。

我们可以 wait 零超时，但我们也可以将其用作 sleep 计时器(在下面使用)。

def doit(stop_event, arg):
    while not stop_event.wait(1):
        print ("working on %s" % arg)
    print("Stopping as you wish.")


def main():
    pill2kill = threading.Event()
    t = threading.Thread(target=doit, args=(pill2kill, "task"))
    t.start()
    time.sleep(5)
    pill2kill.set()
    t.join()

编辑:我在 Python 3.6 中尝试过这个。 stop_event.wait() 阻止事件(以及 while 循环)直到释放。它不返回 bool 值。使用 stop_event.is_set() 代替。

一粒药停止多个线程

如果我们必须停止多个线程，则可以更好地看到丸杀死的优势 一次，因为一粒药对所有人都有效。

doit 根本不会改变，只是 main 处理线程的方式略有不同。

def main():
    pill2kill = threading.Event()
    tasks = ["task ONE", "task TWO", "task THREE"]

    def thread_gen(pill2kill, tasks):
        for task in tasks:
            t = threading.Thread(target=doit, args=(pill2kill, task))
            yield t

    threads = list(thread_gen(pill2kill, tasks))
    for thread in threads:
        thread.start()
    time.sleep(5)
    pill2kill.set()
    for thread in threads:
        thread.join()

关于python - 如何在 Python 中停止循环线程？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/18018033/