python中schedule模塊的使用

使用python進行job管理的schedule模塊，簡單好用，在這里記錄一下。
詳細源碼可以參考這里  https://github.com/dbader/schedule

安裝方法
    pip install schedule

使用方法

import schedule
import time
 
def test():
    print("I'm working...")
def test2():    
    print("I'm working... in job2")
 
# 每10分鍾執行一次job函數
schedule.every(10).minutes.do(test)
# 每10秒執行一次job函數
schedule.every(10).seconds.do(test)
# 當every()沒參數時默認是1小時/分鍾/秒執行一次job函數
schedule.every().hour.do(test)
schedule.every().day.at("10:30").do(test)
schedule.every().monday.do(test)
# 具體某一天某個時刻執行一次job函數
schedule.every().wednesday.at("13:15").do(test)
# 可以同時定時執行多個任務，但是每個任務是按順序執行
schedule.every(10).seconds.do(job2)
# 如果job函數有有參數時，這么寫
schedule.every(10).seconds.do(job，"參數")
while True:
    # 啟動服務
    schedule.run_pending()
    time.sleep(1)

運行該程序之后，可以定時的進行執行。除了代碼中提到的方法之外，還有例如seconds等的一些方法，可以參考源碼。

TIPS

注意，schedule方法是串行的，也就是說，如果各個任務之間時間不沖突，那是沒問題的；如果時間有沖突的話，會串行的執行命令，例如以下代碼

import schedule
import time
import threading

def job():
    print("I'm working... in job1  start")
    time.sleep(15)
    print("I'm working... in job1  end")

def job2():
    print("I'm working... in job2")

schedule.every(10).seconds.do(job)
schedule.every(10).seconds.do(job2)

while True:
    schedule.run_pending()
    time.sleep(1)

輸出如下：

    I’m working… in job1 start
    I’m working… in job1 end
    I’m working… in job2

可以改成多線程的方式：

import schedule
import time
import threading

def job():
    print("I'm working... in job1  start")
    time.sleep(15)
    print("I'm working... in job1  end")

def job2():
    print("I'm working... in job2")

def run_threaded(job_func):
     job_thread = threading.Thread(target=job_func)
     job_thread.start()
       #threading.Thread(target=loop,args=(i,loops[i]))

 schedule.every(10).seconds.do(run_threaded,job)
 schedule.every(10).seconds.do(run_threaded,job2)


while True:
    schedule.run_pending()
    time.sleep(1)

有如下輸出：

    I’m working… in job1 start
    I’m working… in job2
    I’m working… in job1 start
    I’m working… in job2
    I’m working… in job1 end

可見在並行的執行。
如果想要對線程的數量有所控制，“If you want tighter control on the number of threads use a shared jobqueue and one or more worker threads”，則可以采用如下方法：

import Queue
import time
import threading
import schedule


def job():
    print("I'm working")


def worker_main():
    while 1:
        job_func = jobqueue.get()
        job_func()

jobqueue = Queue.Queue()

schedule.every(10).seconds.do(jobqueue.put, job)
schedule.every(10).seconds.do(jobqueue.put, job)
schedule.every(10).seconds.do(jobqueue.put, job)
schedule.every(10).seconds.do(jobqueue.put, job)
schedule.every(10).seconds.do(jobqueue.put, job)

worker_thread = threading.Thread(target=worker_main)
worker_thread.start()

while 1:
    schedule.run_pending()
    time.sleep(1)