Python - 让父线程处理子线程异常

Question

有没有办法让生成新线程的父级捕获生成的线程异常？下面是我想要实现的目标的一个真实的基本示例。当引发异常时它应该停止计数，但我不知道如何捕获它。异常是线程安全的吗？我希望能够使用 Subprocess 模块，但我一直在使用 Python 2.3，并且不知道还能如何做到这一点。可能使用threading模块？

import time
import thread

def test(): 
    try:
        test = thread.start_new_thread(watchdog, (5,))
        count(10)
    except:
        print('Stopped Counting')

def count(num):
    for i in range(num):
        print i
        time.sleep(1)

def watchdog(timeout):
    time.sleep(timeout)
    raise Exception('Ran out of time')

if __name__ == '__main__':
    test()

更新

我原来的代码有点误导。它确实在寻找更像这样的东西：

import time
import thread
import os

def test(): 
    try:
        test = thread.start_new_thread(watchdog, (5,))
        os.system('count_to_10.exe')
    except:
        print('Stopped Counting')

def watchdog(timeout):
    time.sleep(timeout)
    raise Exception('Ran out of time')

if __name__ == '__main__':
    test()

我正在尝试创建一个看门狗，以在程序因某种原因挂起时终止 os.system 调用。

Answer 1

为什么不是这样的事情

def test(): 
    def exeption_cb():
        os._exit()
    test = thread.start_new_thread(watchdog, (5, exception_cb))
    os.system('count_to_10.exe')
    print('Stopped Counting')

def watchdog(timeout, callback):
    time.sleep(timeout)
    callback()

这将停止整个过程。您可以做的另一件事是在不同的线程中启动 os.system，然后倒计时，然后终止该线程。像这样的事情，

def system_call():
    os.system('count_to_10.exe')

system_thread = thread.start_new_thread(system_call)
time.sleep(timeout)
system_thread.kill()

Answer 2

使用 Python 2.3 遇到困难

Python 2.3 已经有 10 年历史了。为什么你还在使用它？

可能使用线程模块

无论如何你都应该使用线程。

但你可能对这个问题的思考是错误的。您可能应该创建一些类并重新考虑解决问题的方法。

此外，如果您正在创建一个看门狗，那么将其与您正在做的事情放在同一进程中可能没有多大意义。 time.sleep() 是一个系统调用，常规的 python Exception 无论如何都不会取消。

Answer 3

如果您真正想做的是传递/处理异常，那么我认为您不想使用子进程，因为父进程只能“查看”子进程生成的状态代码（和输出） -仅在立即发生的情况下子进程中的灾难性失败会在父进程中“重新引发”异常： http ://docs.python.org/library/subprocess.html#exceptions。

而且（如果您尝试传递/处理异常）我也不确定您是否需要线程。毕竟，异常的全部要点（IMO）是拥有一些可以“由调用者”（在 try 块内）处理的东西，或者可以提供有意义的回溯信息（调用序列），如果未处理。这两种想法都无法在一个线程中“抛出”并在另一个线程中“捕获”。

如果您的真正目标是让一个逻辑“超时”另一个逻辑，那么我认为您的“看门狗”是一个单独的进程是有意义的 - 要么是监视“子”输出的“父”（如以及经过的时间），或“监视”诸如受监视进程（以及时钟）的日志行和/或数据库更新之类的“对等点”。在这两种情况下，例外情况都没有特别相关。我建议看一下 Alex Martelli 对这个问题的回答： 使用带有超时的模块“subprocess”

这个问题还有一些与您的问题相关的好答案：
在Python中捕获调用者线程中的线程异常

Answer 4

我知道你被困在使用 Python 2.3 中，但如果你只能对 Python 2.4 做出（非常）适度的进步，那么你可以利用这种更直接的方法，从 Yaroslav Bulatov 给出的答案复制到一个问题（推荐阅读）关于运行带有超时的外部命令：Python，Popen 和 select - 等待要终止的进程或超时

from threading import Timer
from subprocess import Popen, PIPE

def kill_proc():
    proc.kill()

proc = Popen("count_to_10.exe", shell=True)
t = Timer(60, kill_proc)
t.start()
proc.wait()

这是父进程使子进程超时的示例，如我之前的回答中所述。