仅在值更改时触发线程（python）

Question

我正在研究从数据流中读取命令的东西。我被困在试图在 Python 中制作一个可重复使用的非阻塞倒计时，该倒计时可以触发触发器。所以我开始了一个小程序，只有键盘输入和一些基本的线程来计算逻辑。我找到了一些帖子，这篇帖子 (How to create a trigger with threading.Timer?) 非常有帮助。但我需要一些帮助来处理另一部分。

现在我的逻辑是这样的：“每次命令的值为 1 调用开始”

如何将我的逻辑更新为： "如果command的值为1调用start，只要command的值为1就不要再调用start。

因此，它比普通的 if/else 更像是一种值变化检测，或者我必须在某处跟踪布尔值。我只是不确定如何处理它。

#! /usr/bin/env python

import time
import threading
import random
from random import randint
import logging
from sys import argv


logging.basicConfig(level=logging.DEBUG, format='[%(levelname)s] (%(threadName)-10s) %(message)s')

def countdown(pName,command):
    print("{0} countdown - command{1} ".format(pName,command))
    retry = 0
    while True:
        print("{0}:{1}".format(pName,retry))
        retry += 1
        if retry > randint(5,10):
            break
        time.sleep(1)
    print("{0} ended".format(pName))

def start(pName,command):
    print("starting countdown for: ",pName)
    t = threading.Thread(target=countdown,args=(pName,command))
    t.setName(pName)
    t.setDaemon(True)
    t.start()


if __name__ == "__main__":

    while 1:
        command = int(input("[1 or 2] >"))
        if command == 1:
            start("Salad",command)

        elif command == 2:
            start("Bingo",command)

现在这很粗鲁，但它只是第一次尝试解开谜题。

谢谢！

Answer 1

你想要函数isAlive。首先，您必须将您的线程变量移动到 main 函数，以便 main 具有适当的范围来调用 thread.isAlive()。

if __name__ == "__main__":
    tSalad = threading.Thread()
    tBingo = threading.Thread()
    while 1:
        command = int(input("[1 or 2] >"))
        if command == 1 and not tSalad.isAlive():
            tSalad = threading.Thread(target = countdown, args=("Salad", 1))
            start("Salad", tSalad)

        elif command == 2 and not tBingo.isAlive():
            tBingo = threading.Thread(target = countdown, args=("Bingo", 2))
            start("Bingo", tBingo)

然后你修改你的'start'函数来接受一个线程参数：

def start(pName, t):
    print("starting countdown for: ",pName)
    t.setName(pName)
    t.setDaemon(True)
    t.start()

这应该对你有用。