线程被阻塞调用阻塞 - 如何使阻塞调用超时？

Question

我有一个 python 程序，它运行一个外部程序并启动一个超时线程。超时线程应该倒计时10分钟，如果运行外部程序的脚本在这段时间内没有完成，它应该杀死外部程序。

乍一看，我的线程似乎工作正常，我的主脚本和线程同时运行，没有任何问题。但是如果外部程序中出现一个弹出窗口，它会停止我的脚本，因此即使倒计时线程也停止计数，因此完全失败了。

我认为问题在于脚本在 API 中为外部程序调用了一个阻塞函数，该外部程序被弹出窗口阻塞。我理解它为什么会阻塞我的主程序，但不明白它为什么会阻塞我的倒计时线程。因此，一种可能的解决方案可能是为倒计时运行单独的脚本，但我希望它尽可能保持干净，为此启动脚本似乎真的很混乱。

我到处寻找线索，但没有找到太多线索。此处引用了 gevent 库： background function in Python ，但这似乎是一项基本任务，我不想为此包含外部库。

我还找到了一个使用 Windows 多媒体计时器 here 的解决方案，但我以前从未使用过此功能，恐怕代码对此不灵活。脚本仅适用于 Windows，但它应该适用于从 XP 开始的所有 Windows。

对于 Unix，我发现 signal.alarm 似乎完全符合我的要求，但它不适用于 Windows。有什么替代方案吗？

关于如何以最简化的方式使用它的任何想法？

这是我正在创建的简化线程（在 IDLE 中运行以重现问题）：

import threading
import time

class timeToKill():
    def __init__(self, minutesBeforeTimeout):
        self.stop = threading.Event()
        self.countdownFrom = minutesBeforeTimeout * 60

    def startCountdown(self):
        self.countdownThread= threading.Thread(target=self.countdown, args=(self.countdownFrom,))
        self.countdownThread.start()

    def stopCountdown(self):
        self.stop.set()
        self.countdownThread.join()

    def countdown(self,seconds):
        for second in range(seconds):
            if(self.stop.is_set()):
                break
            else:
                print (second)
                time.sleep(1)

timeout = timeToKill(1)
timeout.startCountdown()
raw_input("Blocking call, waiting for input:\n")

Answer 1

对于阻塞另一个 Python 线程的函数调用的一个可能解释是 CPython 使用全局解释器锁 (GIL) 并且阻塞 API 调用不会释放它（注意：CPython 在阻塞 I/O 调用时释放 GIL，因此您的 @ 987654322@ 示例应该按原样工作）。

如果您无法通过错误的 API 调用来释放 GIL，那么您可以使用进程而不是线程，例如，multiprocessing.Process 而不是 threading.Thread（API 相同）。不同的进程不受 GIL 的限制。

Answer 2

为了快速而肮脏的线程，我通常使用子进程命令。它非常健壮且独立于操作系统。它不像线程和队列模块那样提供细粒度的控制，但对于程序的外部调用通常做得很好。注意 shell=True 必须谨慎使用。

#this can be any command
p1 = subprocess.Popen(["python", "SUBSCRIPTS/TEST.py", "0"], shell=True)

#the thread p1 will run in the background - asynchronously.  If you want to kill it after some time, then you need 

#here do some other tasks/computations
time.sleep(10)

currentStatus = p1.poll()
if currentStatus is None: #then it is still running
  try:
    p1.kill() #maybe try os.kill(p1.pid,2) if p1.kill does not work
  except:
    #do something else if process is done running - maybe do nothing?
    pass