python主线程捕获子线程异常

目录

问题抛出:子线程出现异常,主线程仍会正常进行吗

设计实现python主线程捕获子线程异常

需求

问题

解决思路

示例代码


问题抛出:子线程出现异常,主线程仍会正常进行吗

结论:子线程出现异常,主线程仍会正常进行

例子1

测试代码

import threadingdef func(x, m_file):y = 100/(x-5)m_file.write(str(x) + "\n")if __name__ == "__main__":file = open("./test.txt", "w")th_list = []for i in range(0, 10):th = threading.Thread(target=func, args=(i, file))th.start()th_list.append(th)for th in th_list:th.join()file.close()

运行完后报错提示

D:\software\python_3.10.1_32\python.exe D:\hutao\projects\clear_market_data\test.py 
Exception in thread Thread-6 (func):
Traceback (most recent call last):File "D:\software\python_3.10.1_32\lib\threading.py", line 1009, in _bootstrap_innerself.run()File "D:\software\python_3.10.1_32\lib\threading.py", line 946, in runself._target(*self._args, **self._kwargs)File "D:\hutao\projects\clear_market_data\test.py", line 6, in funcy = 100/(x-5)
ZeroDivisionError: division by zeroProcess finished with exit code 0

可以看到只有线程6报错了,但是其它线程和主进程是正常进行的

再次查看test.txt内容

0
1
2
3
4
6
7
8
9

可以看到,内容仅仅没有线程6的结果,说明子线程异常不会影响主线程

例子2

示例代码

import threadingdef func(x):y = 100/(x-5)data_list.append(x)if __name__ == "__main__":data_list = []th_list = []for i in range(10):th = threading.Thread(target=func, args=(i,))th.start()th_list.append(th)for th in th_list:th.join()print(data_list)

运行结果

D:\Python3.6.6\python.exe D:\hutao\projects\grid_trade\test.py 
Exception in thread Thread-6:
Traceback (most recent call last):File "D:\Python3.6.6\lib\threading.py", line 916, in _bootstrap_innerself.run()File "D:\Python3.6.6\lib\threading.py", line 864, in runself._target(*self._args, **self._kwargs)File "D:\hutao\projects\grid_trade\test.py", line 5, in funcy = 100/(x-5)
ZeroDivisionError: division by zero[0, 1, 2, 3, 4, 6, 7, 8, 9]Process finished with exit code 0

设计实现python主线程捕获子线程异常

需求

python多线程时,子线程出现异常,主线程依然正常向下执行,显然不符合工程代码,为解决子线程异常问题,提出研究内容:捕获子线程异常。

捕获子线程异常的好处是:

  • 程序在在多线程处理多个任务时,能够知道每个任务是否正常执行完毕,能够知道是哪个任务出了问题。不然即使子线程出了问题,但整个程序完毕,都不知道出了问题。
  • 在出了问题后,需要快速定位到是哪个地方出了问题。

问题

直接看代码:

def thread_text(i):time.sleep(i)raise Exception(u'error')def main():t = threading.Thread(target=thread_text, args=(1,))t.start()t.join()print(u'end')if __name__ =='__main__':main()

这是一个简单的测试,在子线程中返回一个异常,输出如下:

endException in thread Thread-1:
Traceback (most recent call last):File "/usr/lib/python3.6/threading.py", line 916, in _bootstrap_innerself.run()File "/usr/lib/python3.6/threading.py", line 864, in runself._target(*self._args, **self._kwargs)File "/usercode/file.py", line 8, in thread_textraise Exception(u'error')
Exception: error

可以看到,虽然子线程报出了异常,但main方法依然正常打印出了‘end’,这显然不是我们预期的,接下来,我们开始解决

解决思路

这里用的是queue来实现,它是python3的内置模块,创建堆栈队列,用来处理多线程通信。

queue用法参考:python内置模块之queue(队列)用法-CSDN博客

思路为:当子线程异常,则向queue添加一条数据,可以是任何数据,main方法检测queue是否为空,如果是空的,说明子线程无异常,反之则异常。然后通过检测活跃的线程数来确定子线程是否执行完毕。

更进一步的,添加的那条数据最好是携带更多的信息,比如具体是哪个线程,具体是什么异常信息,以及其它自定义的信息。比如,对于单个任务而言,可能会经过很多步骤,我们需要明确是在哪一步报了错,而且更重要的是如果该任务整体用时非常长,对于报错的任务,是不需要从头开始重新执行的。因此可以设计两个队列变量,一个用来记录错误信息,A,一个用来记录运行过程,B,比如完成一个任务需要10步,每成功运行一步就往B添加一条信息,在某一步报错时就往A添加一条信息。通过查看A和B内的数据,就可以明确是在哪一步报了错,然后检查代码bug等,以及对报错了的线程以及根据A和B中记录的信息来单独处理报错,而不是重新运行那个执行多线程任务的程序。

示例代码

检测活跃的线程数代码

threading.enumerate()  # list 当前活跃的线程,包含主线程
threading.active_count()  # int 当前活跃线程数,包含主线程

输出如下

[<_MainThread(MainThread, started 8628338176)>]
1

好了,思路及用到的模块都介绍完毕,直接上代码

import queue
import threading
import sys
import timedef thread_text(test_queue, i):try:time.sleep(i)raise Exception(u'test_error')except:error_info = sys.exc_info()# error_info = "......"test_queue.put(error_info)if __name__ == '__main__':q = queue.Queue()t = threading.Thread(target=thread_text, args=(q, 1))t.start()while True:if q.empty():if threading.active_count() == 0:breakelse:x = q.get()print(f"({x})")  raise Exception(u'main error')print(u'end')

输出

(<class 'Exception'>, Exception('test_error',), <traceback object at 0x00000256790AA8C8>)
Traceback (most recent call last):File "D:\BaiduSyncdisk\py_project\zs_market\codeList\test.py", line 26, in <module>raise Exception(u'main error')
Exception: main errorProcess finished with exit code 1

可以看到,并没有输出‘end’, 而是返回‘main error’, 说明主线程成功捕获到子线程,这里我是在子线程里queue.put了sys模块的exc_info(),能够更方便查错改错,当然可以是自定义的其它信息,根据需求来。


end

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/web/27119.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【C++进阶学习】第一弹——继承(上)——探索代码复用的乐趣

前言&#xff1a; 在前面&#xff0c;我们已经将C的初阶部分全部讲完了&#xff0c;包括类与对象、STL、栈和队列等众多内容&#xff0c;今天我们就进入C进阶部分的学习&#xff0c;今天先来学习第一弹——继承 目录 一、什么是继承&#xff1f;为什么会有继承&#xff1f; 二…

构建实时搜索与推荐系统:Elasticsearch与业务结合

在当今这个信息爆炸的时代&#xff0c;搜索引擎和推荐系统已成为我们日常生活中不可或缺的一部分。它们不仅帮助我们快速找到所需信息&#xff0c;还根据我们的喜好推荐相关内容&#xff0c;提升了用户体验。本文将探讨如何使用Elasticsearch构建实时搜索与推荐系统&#xff0c…

WPS JS宏获取自动筛选后的行数

//WPS JS宏获取自动筛选后的行数 function getFilterRowCnt(shtRng)//shtRng表示筛选目标工作表范围 {let lngRowCnt 0;for(let rngCell of shtRng.SpecialCells(xlCellTypeVisible).Areas)//获取自动筛选后的单元格行数{lngRowCnt lngRowCnt rngCell.Rows.Count;}return ln…

Web--CSS基础

文章目录 定义方式选择器文本字体背景边框元素展示格式内边距与外边距盒子模型位置浮动实战&#xff1a;个人信息卡片 flex布局响应式布局 定义方式 行内样式表 直接定义在style属性中&#xff0c;作用于当前标签 <img src "/imges/logo.jpg" alt "" …

Vue37-非单文件组件

一、组件的两种编写形式&#xff1a; 非单文件组件&#xff1b;单文件组件。 二、创建一个组件 2-1、组件中的el 组件中不写el&#xff0c;不说为谁服务。 2-2、组件中的data 因为对象形式&#xff0c;多处复用的话&#xff0c;有引用关系&#xff0c;改一处&#xff0c;另一…

atcoder ABC 355-C题详解

atcoder ABC 355-C题详解 ​ Problem Statement There is an NN grid, where the cell at the i-th row from the top and the j-th column from the left contains the integer N(i−1)j. Over T turns, integers will be announced. On Turn i, the integer Ai​ is anno…

[Nacos]No spring.config.import property has been defined

在学习 Spring Cloud Alibaba &#xff0c;Nacos组件&#xff0c;创建一个cloudalibaba-config-nacos-client&#xff0c;加载多配置集时遇到问题 配置了 bootstrap.yml 后启动项目报错&#xff1a; 是因为在springcloud 2020.0.2版本中把bootstrap的相关依赖从spring-cloud-s…

算法分析与设计期末考试复习GDPU

重点内容&#xff1a; 绪论&#xff1a; 简单的递推方程求解 1.19(1)(2) 、 教材例题 多个函数按照阶的大小排序 1.18 分治法&#xff1a; 分治法解决芯片测试问题 计算a^n的复杂度为logn的算法&#xff08;快速幂&#xff09; 分治法解决平面最近点对问…

OpenCV单词轮廓检测

OpenCV单词轮廓检测 0. 前言1. 策略分析2. 检测字符轮廓3. 检测单词轮廓相关链接 0. 前言 在根据文档图像执行单词转录时&#xff0c;通常第一步是识别图像中单词的位置。我们可以使用两种不同的方法识别图像中的单词&#xff1a; 使用 CRAFT、EAST 等深度学习技术使用基于 O…

C++中的解释器模式

目录 解释器模式&#xff08;Interpreter Pattern&#xff09; 实际应用 算术表达式解释器 布尔表达式解释器 总结 解释器模式&#xff08;Interpreter Pattern&#xff09; 解释器模式是一种行为设计模式&#xff0c;它定义了一种语言的文法表示&#xff0c;并使用解释器…

【Python入门与进阶】Python面向对象编程练习

练习题 1&#xff1a;定义一个 Person 类 定义一个 Person 类&#xff0c;它有以下属性和方法&#xff1a; 属性&#xff1a; name&#xff08;字符串&#xff09;&#xff1a;表示人的名字。age&#xff08;整数&#xff09;&#xff1a;表示人的年龄。 方法&#xff1a; __…

用Python处理Excel的资源

用Python处理Excel的资源 python-excel 读写Excel文件 openpyxl openpyx文档l 读写Excel2010文件&#xff08;即xlsx&#xff09; openpyxl示例&#xff1a; from openpyxl import Workbook wb Workbook()# 获取active worksheet ws wb.active# 给单元格赋值 ws[A1] 4…

代码随想录算法训练营第二十六天

题目&#xff1a;455. 分发饼干 贪心第一题 这里的局部最优就是大饼干喂给胃口大的&#xff0c;充分利用饼干尺寸喂饱一个&#xff0c;全局最优就是喂饱尽可能多的小孩。或者小饼干先喂饱小胃口 首先要对 g 和 s进行排序这样才能知道最大的胃口和最大的饼干然后进行遍历即可…

I/O Stream设计实验

实验要求和目的 深入理解java输入输出流相关类的基本用法&#xff0c;并且可以掌握Java程序的编写和调试。 实验环境 Java语言&#xff0c;PC或android平台 实验具体内容 设计和编写以下程序&#xff1a; 程序1&#xff1a; 从键盘读入多行字符串&#xff08;英文&#xf…

(第32天) 513、找树左下角的值 112、路径总和 113、路径总和II

目录 513、找树左下角的值题目描述思路代码112、路径总和题目描述思路代码113、路径总和II题目描述思路代码思考总结513、找树左下角的值 题目描述 给定一个二叉树的 根节点 root,请找出该二叉树的 最底层 最左边 节点的值。 假设二叉树中至少有一个节点。 思路 题目分析:…

ElasticSearch是什么?有哪些应用?有哪些优缺点?

ElasticSearch是什么&#xff1f;有哪些应用&#xff1f;有哪些优缺点&#xff1f; Elasticsearch 是一个开源的分布式搜索和分析引擎&#xff0c;设计用于实时、大规模数据的搜索和分析。它基于Apache Lucene构建&#xff0c;但通过提供一套简单易用的RESTful API、分布式特性…

Web前端接口探秘:深入解析四大方面、五大维度、六大关键及七大实践

Web前端接口探秘&#xff1a;深入解析四大方面、五大维度、六大关键及七大实践 在Web前端开发的广阔领域中&#xff0c;接口作为连接前后端的关键桥梁&#xff0c;扮演着至关重要的角色。本文将带领读者一同深入探索Web前端接口的四大方面、五大维度、六大关键及七大实践&…

Go语言中的函数项模式

函数项模式&#xff08;Functional Options Pattern&#xff09;是一种创造性的设计模式&#xff0c;允许使用接受零个或多个函数作为参数的可变构造函数来构建复杂结构 在没有函数项模式之前&#xff0c;在包初始化加载配置选项的时候&#xff0c;一般有两种做法 编写不同的构…

【微信小程序 事件绑定】

事件绑定 条件渲染 1. block包裹性容器&#xff1a;条件成立渲染 <block wx:if"{{ true }}"><block wx:if"{{true}}"><view>view1</view><view>view2</view> </block>2. wx:if&#xff1a;动态创建移除元素控…

农情监测系统的工作原理

TH-Q3农情监测系统是指利用现代信息技术手段&#xff0c;对农田环境进行实时监测、数据采集、传输和处理&#xff0c;以实现对农田环境的全面感知和智能管理[1]。该系统通过安装各种传感器和监测设备&#xff0c;能够实时监测农田的气象、土壤、植被和其他相关数据&#xff0c;…