分析ejob怎樣擴展quartz

根據(jù)上圖發(fā)現(xiàn)，在創(chuàng)建JobDetail時指定了LiteJob,并注入了其jobExecutor屬性

quartz啟用調(diào)度，最終會觸發(fā)調(diào)用ElasticJobExecutor#execute方法

通過配置quartz配置SimpleThreadPool的線程數(shù)為1
（1）每個定時任務(wù)分配一個單線程池

ElasticJobExecutor#execute執(zhí)行作業(yè)任務(wù)（重點）

從緩存中加載作業(yè)配置（從zk中加載）

檢查是否需要加載可重新加載的項目
2.1 可重新加載的項如下圖

2.2 以線程池重新加載為例分析
（1）對比作業(yè)配置和ExecutorServiceReloadable的jobExecutorServiceHandlerType，如果發(fā)生變化，則重新加載
（2）線程池重新調(diào)整：ExecutorServiceReloadable#reload

guava上發(fā)布JobStatusTraceEvent事件（任務(wù)啟動中狀態(tài)）
3.1 TracingListener#listen方法接收訂閱（@Subscribe）

在任務(wù)執(zhí)行前，遍歷任務(wù)監(jiān)聽器，并執(zhí)行其beforeJobExecuted方法

任務(wù)執(zhí)行：execute(jobConfig, shardingContexts, ExecutionSource.NORMAL_TRIGGER)（下面會詳細分析）

在任務(wù)執(zhí)行后，遍歷任務(wù)監(jiān)聽器，并執(zhí)行其afterJobExecuted方法

ElasticJobExecutor#process（重點）

獲取分片項，初始化分片數(shù)量的CountDownLatch（保證所有分片任務(wù)一起執(zhí)行完）

遍歷分片項，將處理任務(wù)提交到線程池中

線程任務(wù)詳情

4. 發(fā)布任務(wù)執(zhí)行開始事件：JobExecutionEvent
5. 執(zhí)行業(yè)務(wù)代碼邏輯
6. 發(fā)布任務(wù)執(zhí)行結(jié)束事件

總結(jié)

以上是生活随笔為你收集整理的elastic-job调度任务分析的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。