通過sched模塊可以實現通過自定義時間,自定義函數,自定義優先級來執行函數。
范例一
1 import time 2 import sched 3 4 schedule = sched.scheduler( time.time,time.sleep) 5 6 def func(string1): 7 print "now excuted func is %s"%string1 8 9 print "start" 10 schedule.enter(2,0,func,(1,)) 11 schedule.enter(2,0,func,(2,)) 12 schedule.enter(3,0,func,(3,)) 13 schedule.enter(4,0,func,(4,)) 14 schedule.run() 15 16 print "end"
schedule是一個對象,叫什么名字都可以
schedule.enter(delay,priority,action,arguments)
第一個參數是一個整數或浮點數,代表多少秒后執行這個action任務
第二個參數priority是優先級,0代表優先級最高,1次之,2次次之,當
兩個任務是預定在同一個時刻執行時,根據優先級決定誰先執行。
第三個參數就是你要執行的任務,可以簡單理解成你要執行任務的函數的函數名
第四個參數是你要傳入這個定時執行函數名函數的參數,最好用括號包起來,如果只傳入一個
參數的時候用括號包起來,該參數后面一定要加一個逗號,如果不打逗號,會出現錯誤。
例如schedule.enter(delay, priority, action, (argument1,))
run()一直被阻塞,直到所有任務全部執行結束。每個任務在同一線程中運行,所以如果一個任務執行時間大於
其他任務的等待時間,那么其他任務會推遲任務的執行時間,這樣保證沒有任務丟失,但這些任務的調用時間會比設定的推遲。
多線程執行定時任務
范例二
1 import time 2 import sched 3 from threading import Timer 4 def print_name(str): 5 print "i'm %s"%str 6 print "start" 7 Timer(5,print_name,("superman",)).start() 8 Timer(10,print_name,("spiderman",)).start() 9 print "end"
通過多線程,實現定時任務
在多線程中,如果只通過schedule,會因為線程安全的問題會出現阻塞,一個任務執行,如果沒有結束而另一個任務就要等待。
通過threading.Timer可以避免這個問題效果就是直接執行Print start和print end,而定時任務會分開執行。打印end不會阻塞。