av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術(shù)文章
文章詳情頁

python中BackgroundScheduler和BlockingScheduler的區(qū)別

瀏覽:3日期:2022-07-28 08:23:25
目錄1、基本的定時調(diào)度2、BlockingScheduler與BackgroundScheduler區(qū)別

APScheduler最基本的用法: “定時幾秒后啟動job”兩種調(diào)度器: BackgroundScheduler和BlockingScheduler的區(qū)別,job執(zhí)行時間大于定時調(diào)度時間特殊情況的問題及解決方法每個job都會以thread的方式被調(diào)度。

1、基本的定時調(diào)度

APScheduler是python的一個定時任務(wù)調(diào)度框架,能實現(xiàn)類似linux下crontab類型的任務(wù),使用起來比較方便。它提供基于固定時間間隔、日期以及crontab配置類似的任務(wù)調(diào)度,并可以持久化任務(wù),或?qū)⑷蝿?wù)以daemon方式運行。

下面是一個最基本的使用示例:

from apscheduler.schedulers.blocking import BlockingSchedulerdef job(): print(’job 3s’)if __name__==’__main__’: sched = BlockingScheduler(timezone=’MST’) sched.add_job(job, ’interval’, id=’3_second_job’, seconds=3) sched.start()

它能實現(xiàn)每隔3s就調(diào)度job()運行一次,所以程序每隔3s就輸出’job 3s’。通過修改add_job()的參數(shù)seconds,就可以改變?nèi)蝿?wù)調(diào)度的間隔時間。

2、BlockingScheduler與BackgroundScheduler區(qū)別

APScheduler中有很多種不同類型的調(diào)度器,BlockingScheduler與BackgroundScheduler是其中最常用的兩種調(diào)度器。那他們之間有什么區(qū)別呢? 簡單來說,區(qū)別主要在于BlockingScheduler會阻塞主線程的運行,而BackgroundScheduler不會阻塞。所以,我們在不同的情況下,選擇不同的調(diào)度器:

BlockingScheduler: 調(diào)用start函數(shù)后會阻塞當前線程。當調(diào)度器是你應(yīng)用中唯一要運行的東西時(如上例)使用。BackgroundScheduler: 調(diào)用start后主線程不會阻塞。當你不運行任何其他框架時使用,并希望調(diào)度器在你應(yīng)用的后臺執(zhí)行。下面用兩個例子來更直觀的說明兩者的區(qū)別。

BlockingScheduler例子

from apscheduler.schedulers.blocking import BlockingSchedulerimport timedef job(): print(’job 3s’)if __name__==’__main__’: sched = BlockingScheduler(timezone=’MST’) sched.add_job(job, ’interval’, id=’3_second_job’, seconds=3) sched.start() while(True): # 不會被執(zhí)行到print(’main 1s’)time.sleep(1)

運行這個程序,我們得到如下的輸出:

job 3sjob 3sjob 3sjob 3s

可見,BlockingScheduler調(diào)用start函數(shù)后會阻塞當前線程,導(dǎo)致主程序中while循環(huán)不會被執(zhí)行到。

BackgroundScheduler例子

from apscheduler.schedulers.background import BackgroundSchedulerimport timedef job(): print(’job 3s’)if __name__==’__main__’: sched = BackgroundScheduler(timezone=’MST’) sched.add_job(job, ’interval’, id=’3_second_job’, seconds=3) sched.start() while(True):print(’main 1s’)time.sleep(1)

可見,BackgroundScheduler調(diào)用start函數(shù)后并不會阻塞當前線程,所以可以繼續(xù)執(zhí)行主程序中while循環(huán)的邏輯。

main 1smain 1smain 1sjob 3smain 1smain 1smain 1sjob 3s

通過這個輸出,我們也可以發(fā)現(xiàn),調(diào)用start函數(shù)后,job()并不會立即開始執(zhí)行。而是等待3s后,才會被調(diào)度執(zhí)行。如何讓job在start()后就開始運行如何才能讓調(diào)度器調(diào)用start函數(shù)后,job()就立即開始執(zhí)行呢?

其實APScheduler并沒有提供很好的方法來解決這個問題,但有一種最簡單的方式,就是在調(diào)度器start之前,就運行一次job(),如下

from apscheduler.schedulers.background import BackgroundSchedulerimport timedef job(): print(’job 3s’)if __name__==’__main__’: job() # 執(zhí)行一次就好了喲 sched = BackgroundScheduler(timezone=’MST’) sched.add_job(job, ’interval’, id=’3_second_job’, seconds=3) sched.start() while(True):print(’main 1s’)time.sleep(1)

這樣就能得到如下的輸出

job 3smain 1smain 1smain 1sjob 3smain 1smain 1smain 1s

這樣雖然沒有絕對做到“讓job在start()后就開始運行”,但也能做到“不等待調(diào)度,而是剛開始就運行job”。

如果job執(zhí)行時間過長會怎么樣如果執(zhí)行job()的時間需要5s,但調(diào)度器配置為每隔3s就調(diào)用一下job(),會發(fā)生什么情況呢?我們寫了如下例子:

from apscheduler.schedulers.background import BackgroundSchedulerimport timedef job(): print(’job 3s’) time.sleep(5)if __name__==’__main__’: sched = BackgroundScheduler(timezone=’MST’) sched.add_job(job, ’interval’, id=’3_second_job’, seconds=3) sched.start() while(True):print(’main 1s’)time.sleep(1)

運行這個程序,我們得到如下的輸出:

main 1smain 1smain 1sjob 3smain 1smain 1smain 1sExecution of job 'job (trigger: interval[0:00:03], next run at: 2018-05-07 02:44:29 MST)' skipped: maximum number of running instances reached (1)main 1smain 1smain 1sjob 3smain 1s

可見,3s時間到達后,并不會“重新啟動一個job線程”,而是會跳過該次調(diào)度,等到下一個周期(再等待3s),又重新調(diào)度job()。

為了能讓多個job()同時運行,我們也可以配置調(diào)度器的參數(shù)max_instances,如下例,我們允許2個job()同時運行:

from apscheduler.schedulers.background import BackgroundSchedulerimport timedef job(): print(’job 3s’) time.sleep(5)if __name__==’__main__’: job_defaults = { ’max_instances’: 2 } sched = BackgroundScheduler(timezone=’MST’, job_defaults=job_defaults) sched.add_job(job, ’interval’, id=’3_second_job’, seconds=3) sched.start() while(True):print(’main 1s’)time.sleep(1)

運行程序,我們得到如下的輸出:

main 1smain 1smain 1sjob 3smain 1smain 1smain 1sjob 3smain 1smain 1smain 1sjob 3s

每個job是怎么被調(diào)度的

通過上面的例子,我們發(fā)現(xiàn),調(diào)度器是定時調(diào)度job()函數(shù),來實現(xiàn)調(diào)度的。

那job()函數(shù)會被以進程的方式調(diào)度運行,還是以線程來運行呢?

為了弄清這個問題,我們寫了如下程序:

from apscheduler.schedulers.background import BackgroundSchedulerimport time,os,threadingdef job(): print(’job thread_id-{0}, process_id-{1}’.format(threading.get_ident(), os.getpid())) time.sleep(50)if __name__==’__main__’: job_defaults = { ’max_instances’: 20 } sched = BackgroundScheduler(timezone=’MST’, job_defaults=job_defaults) sched.add_job(job, ’interval’, id=’3_second_job’, seconds=3) sched.start() while(True):print(’main 1s’)time.sleep(1)

運行程序,我們得到如下的輸出:

main 1smain 1smain 1sjob thread_id-10644, process_id-8872main 1smain 1smain 1sjob thread_id-3024, process_id-8872main 1smain 1smain 1sjob thread_id-6728, process_id-8872main 1smain 1smain 1sjob thread_id-11716, process_id-8872

可見,每個job()的進程ID都相同,但線程ID不同。所以,job()最終是以線程的方式被調(diào)度執(zhí)行。

到此這篇關(guān)于python中BackgroundScheduler和BlockingScheduler的區(qū)別 的文章就介紹到這了,更多相關(guān)python BackgroundScheduler BlockingScheduler內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)!

標簽: Python 編程
相關(guān)文章:
主站蜘蛛池模板: 99热国产免费 | 久久精品在线 | 久久久久久久久毛片 | av一级 | 国产 日韩 欧美 中文 在线播放 | 亚洲欧美视频 | 国产精品国产三级国产aⅴ中文 | 亚洲欧美日韩在线 | 成人在线视频网 | 精品视频在线观看 | 久久久精选 | 中文字幕av在线播放 | 麻豆久久久久久久久久 | 国产精成人 | 中国黄色毛片视频 | 精久久| 一本色道久久综合亚洲精品高清 | 国产免费福利小视频 | 国产二区三区 | 一区二区在线不卡 | 午夜视频一区二区三区 | 国产视频1区 | 奇米久久久 | 蜜臀久久99精品久久久久久宅男 | av网站在线播放 | 精品欧美二区 | 欧美视频在线播放 | 日韩福利 | 婷婷久久网| 国产免费一区二区三区网站免费 | 亚洲二区在线 | 国产成人精品久久二区二区91 | 毛片毛片毛片毛片毛片 | 日本三级日产三级国产三级 | 日韩精品一区二区三区中文字幕 | 国产精品久久久久久久久久久免费看 | 欧美韩一区二区 | 手机在线不卡av | www.日本三级 | 3级毛片 | 黄色在线免费观看 |