python多线程程序运行中,会出现由于异常而导致某线程停止的情况,为了保证程序的稳定运行,需要自动重启下掉的线程。
python线程类有一个setName()的方法,可以为线程设置名字。
threading.enumerate()可以获取当前的线程对象。
<>强自动重启线程的思路如下:
1。使用setName()每个线程设置名字;
2。在初始化运行时使用threading.enumerate()获取当前所有线程对象,保存为初始线程组;
3。隔一段时间使用threading.enumerate()获取当前所有线程对象,与初始线程组对比,如果某个名字缺失,则重新开始。
下面举个例子:
utf - 8编码:
进口线程
list_ip=[“1.1.1.1”、“2.2.2.2”、“3.3.3.3”) #一组ip列表
def printIP (ip):
打印的ip
# 180年代每获取当前线程名,并跟初始线程组比较,某一线程停止后自动运行
def checkThread (sleeptimes=180, initThreadsName=[]):
因为我在范围(0,10080):#循环运行
nowThreadsName=[] #用来保存当前线程名称
现在=threading.enumerate() #获取当前线程名
我现在在:
nowThreadsName.append (i.getName()) #保存当前线程名称
对ip initThreadsName:
如果ip nowThreadsName:
通过#当前某线程名包含在初始化线程组中,可以认为线程仍在运行
其他:
打印的===+ ip,“现在停止,重新启动”
t=threading.Thread(目标=printIP args=(ip)) #重启线程
t.setName (ip) #重设的名字
t.start ()
time . sleep (sleeptimes) #隔一段时间重新运行,检测有没有线程
if __name__==癬_main__”:
线程=[]
initThreadsName=[] #保存初始化线程组名字
对ip list_ip:
t=threading.Thread(目标=printIP args=(ip))
t.setName (ip)
threads.append (t)
在线程t:
t.start ()
init=threading.enumerate() #获取初始化的线程对象
因为我在初始化:
initThreadsName.append (i.getName()) #保存初始化线程组名字
检查=threading.Thread(目标=checkThread args=(180年,initThreadsName)) #用来检测是否有线程下来并重启下来线程
check.setName(线程:检查)
check.start ()
之前
以上这篇python多线程重启方法就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。
