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 块内），或者可以提供 有意义的 回溯信息（调用序列），如果未处理。这两种想法都不能真正适用于一个线程中的“throw”和另一个线程中的“catch”。

如果您的真正目标是让一个逻辑“超时”另一个逻辑，那么我认为将您的“看门狗”作为一个单独的进程是有意义的 - 要么是监视来自“孩子”的输出的“父母” ”（以及经过的时间），或者一个“对等”，它“监视”受监视进程（以及时钟）的日志行和/或数据库更新之类的东西。在这两种情况下，例外情况都不是特别相关。我建议看看 Alex Martelli 对这个问题的回答：Using module 'subprocess' with timeout

这个问题也有几个与您的问题相关的好答案： Catch a thread's exception in the caller thread in Python

Answer 4

我知道您在使用 Python 2.3 时遇到了困难，但如果您只能对 Python 2.4 进行（非常）适度的改进，那么您可以利用这种更直接的方法，复制自 Yaroslav Bulatov 对问题的回答（推荐阅读）关于超时运行外部命令：Python, Popen and select - waiting for a process to terminate or a timeout

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()

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