Python多线程异常自动重启机制实现

南乔

发布时间：2026-10-13| 7人浏览过

原创

本文介绍Python中多线程程序因异常导致线程停止时的自动重启方案。通过threading模块的setName和enumerate方法，记录初始线程组并定期对比，发现缺失线程时立即重新创建并启动，确保程序稳定运行。

在Python多线程程序运行过程中，可能会因异常导致某个线程意外终止。为了保证程序的稳定运行，需要实现自动重启已停止线程的机制。

Python的Threading类提供了setName()方法，可用于为线程设置自定义名称。

threading.enumerate()函数可以获取当前所有活跃线程的对象列表。

实现自动重启线程的基本思路如下：

1. 使用setName()为每个线程分配唯一名称；

2. 在程序初始化阶段，利用threading.enumerate()获取当前所有线程对象，并保存为初始线程组；

3. 定期调用threading.enumerate()获取当前线程对象，与初始线程组进行对比。若发现某个线程名称缺失，则重新创建并启动该线程。

以下是一个具体实现示例：

#coding:utf-8
import threading

list_ip=['1.1.1.1','2.2.2.2','3.3.3.3'] #一组ip列表

def printIP(ip):
  print ip

#每180s获取当前线程名，并跟初始线程组比较，某一线程停止后自动运行
def checkThread(sleeptimes=180,initThreadsName=[]):
  for i in range(0,10080):#循环运行
    nowThreadsName=[]#用来保存当前线程名称
    now=threading.enumerate()#获取当前线程名
    for i in now:
      nowThreadsName.append(i.getName())#保存当前线程名称

    for ip in initThreadsName:
      if ip in nowThreadsName:
        pass #当前某线程名包含在初始化线程组中，可以认为线程仍在运行
      else:
        print '==='+ip,'stopped，now restart'
        t=threading.Thread(target=printIP,args=(ip,))#重启线程
        t.setName(ip)#重设name
        t.start()
    time.sleep(sleeptimes)#隔一段时间重新运行，检测有没有线程down


if __name__ == '__main__':
  threads=[]
  initThreadsName=[]#保存初始化线程组名字
  for ip in list_ip:
    t=threading.Thread(target=printIP,args=(ip,))
    t.setName(ip)
    threads.append(t)

  for t in threads:
    t.start()

  init=threading.enumerate()#获取初始化的线程对象
  for i in init:
    initThreadsName.append(i.getName())#保存初始化线程组名字

  check=threading.Thread(target=checkThread,args=(180,initThreadsName))#用来检测是否有线程down并重启down线程
  check.setName('Thread:check')
  check.start()

以上关于Python多线程自动重启方法的介绍到此结束，希望能为读者提供参考。感谢支持，欢迎继续探索相关技术内容。