python的線程有一個(gè)類叫Timer可以,用來創(chuàng)建定時(shí)任務(wù),但是它的問題是只能運(yùn)行一次,如果要重復(fù)執(zhí)行,則只能在任務(wù)中再調(diào)用一次timer,但這樣就存在新的問題了,就是在主進(jìn)程退出后,不能正常退出子線程。
from threading import Timer def scheduletaskwrap(): pritn "in task" Timer(10, scheduletaskwrap).start() Timer(10, scheduletaskwrap).start()
象上面這樣,就可以每10秒調(diào)用一次線程,但是當(dāng)你退出整個(gè)程序后,子線程
scheduletaskwrap
還在繼續(xù)執(zhí)行,要通知它退出怎么辦?
python的線程模塊提供了很多辦法,什么event,wait,lock等,這些都比較麻煩不適合這種定時(shí)任務(wù)的簡(jiǎn)單方法。
最簡(jiǎn)單的就是設(shè)置一個(gè)全局變量,然后在線程中判斷它是否改變。
from threading import Timergflag=1 def scheduletaskwrap(): global gflag pritn "in task" if gflag==1: Timer(10, scheduletaskwrap).start() Timer(10, scheduletaskwrap).start()
想象是美好的,你實(shí)際運(yùn)行就會(huì)發(fā)現(xiàn),這樣行不通,因?yàn)橹鬟M(jìn)程退出后,那個(gè)全局變量,在子線程中還是1,沒有改變,因?yàn)閜ython不存在什么退出通知之類的機(jī)制。
那沒有其他辦法了嗎?經(jīng)過思考,既然進(jìn)程沒有退出通知,但是類可以啊,類一般都有析構(gòu)函數(shù),可以用它來實(shí)現(xiàn)全局變量的改變,于是添加了一個(gè)類,在析構(gòu)函數(shù)中把全局變量改成0,這樣就可以了。
class timerexec(): threadhandle=0 def __init__(self,thandle): threadhandle=thandle def __del__(self): global gflag gflag=0 print u"線程結(jié)束",gflag threadhandle.cancel
refreshthread=Timer(10, scheduletaskwrap).start() a=timerexec(refreshthread)
主進(jìn)程中調(diào)用timer的地方也要添加創(chuàng)建類的代碼。
這樣就可以了。
以上這篇解決Python中定時(shí)任務(wù)線程無法自動(dòng)退出的問題就是小編分享給大家的全部?jī)?nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持武林站長(zhǎng)站。
新聞熱點(diǎn)
疑難解答
圖片精選