python 多線程程序運行中,會出現由于異常而導致某線程停止的情況,為了保證程序的穩定運行,需要自動重啟down掉的線程.
python Threading類有一個setName()的方法,可以為線程設置名字。
threading.enumerate()可以獲取當前的線程對象。
自動重啟線程的思路如下:
1.使用setName()每個線程設置名字;
2.在初始化運行時使用threading.enumerate()獲取當前所有線程對象,保存為初始線程組;
3.隔一段時間使用threading.enumerate()獲取當前所有線程對象,與初始線程組對比,如果某個name缺失,則重新start。
下面舉個例子:
#coding:utf-8import threadinglist_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)#隔一段時間重新運行,檢測有沒有線程downif __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 多線程重啟方法就是小編分享給大家的全部內容了,希望能給大家一個參考,也希望大家多多支持武林站長站。
新聞熱點
疑難解答