python 多線程重啟方法

#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獲取當(dāng)前線程名，并跟初始線程組比較，某一線程停止后自動(dòng)運(yùn)行
def checkThread(sleeptimes=180,initThreadsName=[]):
  for i in range(0,10080):#循環(huán)運(yùn)行
    nowThreadsName=[]#用來保存當(dāng)前線程名稱
    now=threading.enumerate()#獲取當(dāng)前線程名
    for i in now:
      nowThreadsName.append(i.getName())#保存當(dāng)前線程名稱

    for ip in initThreadsName:
      if ip in nowThreadsName:
        pass #當(dāng)前某線程名包含在初始化線程組中，可以認(rèn)為線程仍在運(yùn)行
      else:
        print '==='+ip,'stopped，now restart'
        t=threading.Thread(target=printIP,args=(ip,))#重啟線程
        t.setName(ip)#重設(shè)name
        t.start()
    time.sleep(sleeptimes)#隔一段時(shí)間重新運(yùn)行，檢測(cè)有沒有線程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()#獲取初始化的線程對(duì)象
  for i in init:
    initThreadsName.append(i.getName())#保存初始化線程組名字

  check=threading.Thread(target=checkThread,args=(180,initThreadsName))#用來檢測(cè)是否有線程down并重啟down線程
  check.setName('Thread:check')
  check.start()