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

    for ip in initThreadsName:
      if ip in nowThreadsName:
        pass #當(dāng)前某線(xiàn)程名包含在初始化線(xiàn)程組中，可以認(rèn)為線(xiàn)程仍在運(yùn)行
      else:
        print '==='+ip,'stopped，now restart'
        t=threading.Thread(target=printIP,args=(ip,))#重啟線(xiàn)程
        t.setName(ip)#重設(shè)name
        t.start()
    time.sleep(sleeptimes)#隔一段時(shí)間重新運(yùn)行，檢測(cè)有沒(méi)有線(xiàn)程down


if __name__ == '__main__':
  threads=[]
  initThreadsName=[]#保存初始化線(xiàn)程組名字
  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()#獲取初始化的線(xiàn)程對(duì)象
  for i in init:
    initThreadsName.append(i.getName())#保存初始化線(xiàn)程組名字

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