如何在Python中捕获调用者线程中的线程异常？

在调用者线程中捕获线程的异常

多线程编程，任务并发执行，提供处理复杂操作的效率。然而，线程中遇到的异常可能变得难以管理。在 Python 中，标准的“try- except”块可能无法处理子线程中引发的异常。本文探讨了一种从调用者线程中的线程捕获异常的技术，使开发人员能够有效地处理它们。

理解问题

考虑以下场景：脚本执行文件在单独的线程中复制，目的是显示进度指示器。但是，当文件复制失败时，线程内会抛出异常。下面的代码片段尝试处理这个异常：

try:
    threadClass = TheThread(param1, param2, etc.)
    threadClass.start()   ##### **Exception takes place here**
except:
    print "Caught an exception"

不幸的是，这种方法失败了，因为“start”方法立即返回，导致异常在子线程的上下文中发生。异常堆栈跟踪在该线程内保持隔离，使得调用者线程无法访问它。

解决异常

要解决此问题，一种有希望的方法是使用消息传递。通过使用消息队列，异常可以从子线程传递到调用者线程。下面是一个示例实现：

import sys
import threading
import queue


class ExcThread(threading.Thread):

    def __init__(self, bucket):
        threading.Thread.__init__(self)
        self.bucket = bucket

    def run(self):
        try:
            raise Exception('An error occured here.')
        except Exception:
            self.bucket.put(sys.exc_info())


def main():
    bucket = queue.Queue()
    thread_obj = ExcThread(bucket)
    thread_obj.start()

    while True:
        try:
            exc = bucket.get(block=False)
        except queue.Empty:
            pass
        else:
            exc_type, exc_obj, exc_trace = exc
            # deal with the exception
            print exc_type, exc_obj
            print exc_trace

        thread_obj.join(0.1)
        if thread_obj.isAlive():
            continue
        else:
            break


if __name__ == '__main__':
    main()

说明：

• ExcThread：自定义线程类，将异常信息放入名为存储桶的消息队列中。
• main：使用非阻塞 get 连续检查队列中是否有异常的调用者线程
• exc_type, exc_obj, exc_trace：检索到的可进行相应处理的异常内容。

结论

通过使用消息传递技术，可以实现从子线程捕获异常并在调用者线程中有效地处理它们。这使开发人员能够快速解决潜在错误，从而开发出更强大、响应更灵敏的多线程应用程序。

以上是如何在Python中捕获调用者线程中的线程异常？的详细内容。更多信息请关注PHP中文网其他相关文章！