Quartz-QuartzSchedulerThread詳解

QuartzSchedulerThread詳解

QuartzSchedulerThread是一個線程類纲刀,負責查詢并觸發(fā)Triggers。

public class QuartzSchedulerThread extends Thread {
    QuartzSchedulerThread(QuartzScheduler qs, QuartzSchedulerResources qsRsrcs, boolean setDaemon, int threadPrio) {
        super(qs.getSchedulerThreadGroup(), qsRsrcs.getThreadName());
        ........
        paused = true;
        halted = new AtomicBoolean(false);
    }
}

該線程類的主要工作分為以下幾個步驟:

  • 等待QuartzScheduler啟動
  • 查詢待觸發(fā)的Trigger
  • 等待Trigger觸發(fā)時間到來
  • 觸發(fā)Trigger
  • 循環(huán)上述步驟
/*-----------------run()方法有刪減----------------------*/
public void run() {
    while (!halted.get()) {
        // -------------------------------
        // 1 等待QuartzScheduler啟動
        // -------------------------------
        synchronized (sigLock) {
            while (paused && !halted.get()) {
                // wait until togglePause(false) is called...
                sigLock.wait(1000L);
            }
        }

        // -------------------------------
        // 2 查詢待觸發(fā)的Trigger
        // -------------------------------
        int availThreadCount = qsRsrcs.getThreadPool().blockForAvailableThreads();
        if(availThreadCount > 0) { // will always be true, due to semantics of blockForAvailableThreads...
            // 查詢未來(now + idletime)時間內待觸發(fā)的Triggers
            // triggers是按觸發(fā)時間由近及遠排序的集合
            List<OperableTrigger> triggers = qsRsrcs.getJobStore().acquireNextTriggers(
                    now + idleWaitTime, Math.min(availThreadCount, qsRsrcs.getMaxBatchSize()), qsRsrcs.getBatchTimeWindow());
            if (triggers != null && !triggers.isEmpty()) {
                now = System.currentTimeMillis();
                long triggerTime = triggers.get(0).getNextFireTime().getTime();
                long timeUntilTrigger = triggerTime - now;
                // 通過循環(huán)阻塞担平,等待第一個Trigger觸發(fā)時間
                while(timeUntilTrigger > 2) {
                    synchronized (sigLock) {
                        if (halted.get()) {
                            break;
                        }
                    }
                    now = System.currentTimeMillis();
                    timeUntilTrigger = triggerTime - now;
                }
            // 通知JobStore示绊,這些Triggers將要被觸發(fā)
            List<TriggerFiredResult> res = qsRsrcs.getJobStore().triggersFired(triggers);
            if(res != null)
                bndles = res;
            }
            // -------------------------------
            // 3 觸發(fā)Triggers
            // -------------------------------
            for (int i = 0; i < bndles.size(); i++) {
                TriggerFiredResult result =  bndles.get(i);
                TriggerFiredBundle bndle =  result.getTriggerFiredBundle();
                JobRunShell shell = qsRsrcs.getJobRunShellFactory().createJobRunShell(bndle);
                shell.initialize(qs);
                qsRsrcs.getThreadPool().runInThread(shell);
            }
            continue; // while (!halted)
        } else { // if(availThreadCount > 0)
            // should never happen, if threadPool.blockForAvailableThreads() follows contract
            continue; // while (!halted)
        }
    } // while (!halted)
}

1 等待QuartzScheduler啟動

synchronized (sigLock) {
    while (paused && !halted.get()) {
        // wait until togglePause(false) is called...
        sigLock.wait(1000L);
    }
}

循環(huán)檢查paused && !halted.get()條件是否滿足,否則釋放sigLock對象的鎖暂论,并等待面褐,一秒后重試。
QuartzScheduler對象創(chuàng)建并調用start()方法時取胎,將喚醒QuartzSchedulerThread線程展哭,即可跳出阻塞塊,繼續(xù)執(zhí)行闻蛀。

/*QuartzScheduler*/
public void start() throws SchedulerException {
    ....
    schedThread.togglePause(false);
    ....
}

/*QuartzSchedulerThread*/
void togglePause(boolean pause) {
    synchronized (sigLock) {
        // 更改暫停狀態(tài)
        paused = pause;
        if (paused) {
            signalSchedulingChange(0);
        } else {
            // 喚醒在sigLock上等待的所有線程
            sigLock.notifyAll();
        }
    }
}

2 查詢待觸發(fā)的Trigger

Quartz未雨綢繆匪傍,從JobStore中獲取當前時間后移一段時間內(idle time + time window)將要觸發(fā)的Triggers,以及在當前時間前移一段時間內(misfireThreshold)錯過觸發(fā)的Triggers(這里僅查詢Trigger的主要信息)觉痛。被查詢到的Trggers狀態(tài)變化:STATE_WAITING-->STATE_ACQUIRED役衡。結果集是以觸發(fā)時間升序、優(yōu)先級降序的集合薪棒。

public List<TriggerKey> selectTriggerToAcquire(Connection conn, long noLaterThan, long noEarlierThan, int maxCount)
        throws SQLException {
}
SELECT
    TRIGGER_NAME,
    TRIGGER_GROUP,
    NEXT_FIRE_TIME,
    PRIORITY
FROM
    QRTZ_TRIGGERS
WHERE
    SCHED_NAME = 'TestScheduler'
AND TRIGGER_STATE = ?
AND NEXT_FIRE_TIME <= ?
AND (
    MISFIRE_INSTR = - 1
    OR (
        MISFIRE_INSTR != - 1
        AND NEXT_FIRE_TIME >= ?
    )
)
ORDER BY
    NEXT_FIRE_TIME ASC,
    PRIORITY DESC

3 等待Trigger觸發(fā)時間到來

因為上一步取得的Triggers是按時間排序的集合手蝎,所以取集合中的第一個榕莺,即觸發(fā)時間最早的Trigger,等待其觸發(fā)時間的到來柑船。老套路while循環(huán)+wait實現(xiàn)帽撑。
不過需要注意的是,在此期間鞍时,可能有一些新的情況發(fā)生,比如說扣蜻,新增了一個Trigger逆巍,并且該新增的Trigger比前面獲取的觸發(fā)時間都早,那么就需要將上面獲取的Trigger釋放掉(狀態(tài)變化:STATE_ACQUIRED-->STATE_WAITING)莽使,然后重新查詢Trggers

now = System.currentTimeMillis();
long triggerTime = triggers.get(0).getNextFireTime().getTime();
long timeUntilTrigger = triggerTime - now;
// 當觸發(fā)時間距當前時間<=2 ms時锐极,結束循環(huán)
while(timeUntilTrigger > 2) {
    synchronized (sigLock) {
        if (halted.get()) {
            break;
        }
        // 判斷在此過程中是否有新增的并且觸發(fā)時間更早的Trigger
        // 但是此處有個權衡,為了一個新增的的Trigger而丟棄當前已獲取的是否值得芳肌?
        // 丟棄當前獲取的Trigger并重新獲取需要花費一定的時間灵再,時間的長短與JobStore的實現(xiàn)有關。
        // 所以此處做了主觀判斷亿笤,如果使用的是數(shù)據(jù)庫存儲翎迁,查詢時間假定為70ms,內存存儲假定為7ms
        // 如果當前時間距已獲得的第一個Trigger觸發(fā)時間小于查詢時間净薛,則認為丟棄是不合算的汪榔。
        if (!isCandidateNewTimeEarlierWithinReason(triggerTime, false)) {
            try {
                // we could have blocked a long while
                // on 'synchronize', so we must recompute
                now = System.currentTimeMillis();
                timeUntilTrigger = triggerTime - now;
                // 距觸發(fā)時間太早,先休息會吧
                if(timeUntilTrigger >= 1)
                    sigLock.wait(timeUntilTrigger);
            } catch (InterruptedException ignore) {
            }
        }
    }
    // 如果有新增的且觸發(fā)時間更早的Trigger過來攪局肃拜,則釋放上面已獲取的Trigger痴腌,等待下一波查詢
    if(releaseIfScheduleChangedSignificantly(triggers, triggerTime)) {
        break;
    }
    now = System.currentTimeMillis();
    timeUntilTrigger = triggerTime - now;
}

4 觸發(fā)Trigger

前面提到過,先前只是獲取Trigger的主要信息燃领,其關聯(lián)的Job士聪、Calendar等信息是在觸發(fā)前獲取的。待Trigger所需信息驗證猛蔽、關聯(lián)完成后剥悟,先行將Trigger的狀態(tài)改為STATE_ACQUIRED-->STATE_COMPLETE。而后將Trigger封裝后的TriggerFiredResult對象交由JobRunShell執(zhí)行枢舶。

List<TriggerFiredResult> res = qsRsrcs.getJobStore().triggersFired(triggers);
for (int i = 0; i < bndles.size(); i++) {
    TriggerFiredResult result =  bndles.get(i);
    TriggerFiredBundle bndle =  result.getTriggerFiredBundle();
    JobRunShell shell = qsRsrcs.getJobRunShellFactory().createJobRunShell(bndle);
    shell.initialize(qs);
    qsRsrcs.getThreadPool().runInThread(shell);
}
最后編輯于
?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
  • 序言:七十年代末懦胞,一起剝皮案震驚了整個濱河市,隨后出現(xiàn)的幾起案子凉泄,更是在濱河造成了極大的恐慌躏尉,老刑警劉巖,帶你破解...
    沈念sama閱讀 210,914評論 6 490
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件后众,死亡現(xiàn)場離奇詭異胀糜,居然都是意外死亡颅拦,警方通過查閱死者的電腦和手機,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 89,935評論 2 383
  • 文/潘曉璐 我一進店門教藻,熙熙樓的掌柜王于貴愁眉苦臉地迎上來距帅,“玉大人,你說我怎么就攤上這事括堤÷到眨” “怎么了?”我有些...
    開封第一講書人閱讀 156,531評論 0 345
  • 文/不壞的土叔 我叫張陵悄窃,是天一觀的道長讥电。 經(jīng)常有香客問我,道長轧抗,這世上最難降的妖魔是什么恩敌? 我笑而不...
    開封第一講書人閱讀 56,309評論 1 282
  • 正文 為了忘掉前任,我火速辦了婚禮横媚,結果婚禮上纠炮,老公的妹妹穿的比我還像新娘。我一直安慰自己灯蝴,他們只是感情好恢口,可當我...
    茶點故事閱讀 65,381評論 5 384
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著绽乔,像睡著了一般弧蝇。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上折砸,一...
    開封第一講書人閱讀 49,730評論 1 289
  • 那天看疗,我揣著相機與錄音,去河邊找鬼睦授。 笑死两芳,一個胖子當著我的面吹牛,可吹牛的內容都是我干的去枷。 我是一名探鬼主播怖辆,決...
    沈念sama閱讀 38,882評論 3 404
  • 文/蒼蘭香墨 我猛地睜開眼,長吁一口氣:“原來是場噩夢啊……” “哼删顶!你這毒婦竟也來了竖螃?” 一聲冷哼從身側響起,我...
    開封第一講書人閱讀 37,643評論 0 266
  • 序言:老撾萬榮一對情侶失蹤逗余,失蹤者是張志新(化名)和其女友劉穎特咆,沒想到半個月后,有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體录粱,經(jīng)...
    沈念sama閱讀 44,095評論 1 303
  • 正文 獨居荒郊野嶺守林人離奇死亡腻格,尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內容為張勛視角 年9月15日...
    茶點故事閱讀 36,448評論 2 325
  • 正文 我和宋清朗相戀三年画拾,在試婚紗的時候發(fā)現(xiàn)自己被綠了。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片菜职。...
    茶點故事閱讀 38,566評論 1 339
  • 序言:一個原本活蹦亂跳的男人離奇死亡青抛,死狀恐怖,靈堂內的尸體忽然破棺而出酬核,到底是詐尸還是另有隱情蜜另,我是刑警寧澤,帶...
    沈念sama閱讀 34,253評論 4 328
  • 正文 年R本政府宣布愁茁,位于F島的核電站蚕钦,受9級特大地震影響,放射性物質發(fā)生泄漏鹅很。R本人自食惡果不足惜,卻給世界環(huán)境...
    茶點故事閱讀 39,829評論 3 312
  • 文/蒙蒙 一罪帖、第九天 我趴在偏房一處隱蔽的房頂上張望促煮。 院中可真熱鬧,春花似錦整袁、人聲如沸菠齿。這莊子的主人今日做“春日...
    開封第一講書人閱讀 30,715評論 0 21
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽绳匀。三九已至,卻和暖如春炸客,著一層夾襖步出監(jiān)牢的瞬間疾棵,已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 31,945評論 1 264
  • 我被黑心中介騙來泰國打工痹仙, 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留是尔,地道東北人。 一個月前我還...
    沈念sama閱讀 46,248評論 2 360
  • 正文 我出身青樓开仰,卻偏偏與公主長得像拟枚,于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子众弓,可洞房花燭夜當晚...
    茶點故事閱讀 43,440評論 2 348

推薦閱讀更多精彩內容

  • Spring Cloud為開發(fā)人員提供了快速構建分布式系統(tǒng)中一些常見模式的工具(例如配置管理恩溅,服務發(fā)現(xiàn),斷路器谓娃,智...
    卡卡羅2017閱讀 134,626評論 18 139
  • 1. Java基礎部分 基礎部分的順序:基本語法脚乡,類相關的語法,內部類的語法傻粘,繼承相關的語法每窖,異常的語法帮掉,線程的語...
    子非魚_t_閱讀 31,596評論 18 399
  • Quartz 主要API Scheduler 任務調度器,按照特定的觸發(fā)規(guī)則窒典,自動執(zhí)行任務 Job 接口蟆炊,定義需要...
    Impler閱讀 1,157評論 0 0
  • Android 自定義View的各種姿勢1 Activity的顯示之ViewRootImpl詳解 Activity...
    passiontim閱讀 171,726評論 25 707
  • 很動聽。心感抱歉瀑志,如果我寫的東西有人在看涩搓,可能又要讓人覺得重復了,除了分享這美妙的音樂劈猪,我不太想寫其他的昧甘。 我聽的...
    Leonor_Z閱讀 486評論 0 0