一、Python線程為什么搞個setDaemon
當啟動一個線程時設置thread.setDaemon(True),則該線程為守護線程(也可以稱為后臺線程)。表示該線程是不重要的,進程退出時不需要等待這個線程執(zhí)行完成。這樣做的意義在于:避免子線程無限死循環(huán),導致退不出程序,也就是避免了孤兒進程的出現(xiàn)。
當不設置或者thread.setDaemon(False)時,主進程執(zhí)行結束時,會等待線程結束。
應用:如保持網絡連接(發(fā)送keep-alive心跳包)或者后臺監(jiān)控的線程,負責內存管理與垃圾回收(實際上JVM就是這樣做的),這些線程與實際提供應用服務的線程有了邏輯上的”前/后”的概念,而如果主線程已經退出,那么這些后臺線程也沒有存在的必要。
如果沒有這一機制,那么我們在主線程完成之后,還必須逐個地檢查后臺線程,然后在主線程退出之前,逐個地關閉它們. 有了前后線程的區(qū)分, 我們只需要負責管理前臺線程, 完成主要的邏輯處理之后退出即可。
當子線程不設置時,主進程結束后,子線程會繼續(xù)執(zhí)行完后,程序結束。
import time
from hashlib import md5
from threading import Thread
def pmd(md):
?? ?time.sleep(3) #使用sleep使得該線程比主線程晚結束
??? print(“backend recording:”,md)
def giveures(s):
??? md = md5(s.encode(‘utf-8’))
??? res = md.digest()
??? t = Thread(target=pmd,args=(s,))
??? #t.setDaemon(True) 默認情況:t.setDaemon(False)
??? t.start()
??? return res
s = ‘chrisyang’
res = giveures(s)
print(res)
當設置時,主進程不會等待子線程,當主線程結束,子線程就會被強制停止運行并回收。
import time
from hashlib import md5
from threading import Thread
def pmd(md):
??? time.sleep(3) #使用sleep使得該線程比主線程晚結束
??? print(“backend recording:”,md)
def giveures(s):
??? md = md5(s.encode(‘utf-8’))
??? res = md.digest()
??? t = Thread(target=pmd,args=(s,))
??? t.setDaemon(True)
??? t.start()
??? return res
s = ‘chrisyang’
res = giveures(s)
print(res)
延伸閱讀:
二、異步消息隊列
說道消息隊列,你肯定會想到Kafka、Rabbitmq等消息中間件,這些專業(yè)的消息中間件提供了很多功能特性,當然他的部署使用維護都是比較麻煩的。如果你對消息隊列沒那么高要求,想要輕量級的,使用Redis就沒錯啦。
Redis通過list數(shù)據(jù)結構來實現(xiàn)消息隊列.主要使用到如下命令:
lpush和rpush入隊列l(wèi)pop和rpop出隊列blpop和brpop阻塞式出隊列