[發(fā)明專(zhuān)利]一種作業(yè)調(diào)度方法和系統(tǒng)

無(wú)效

• 申請(qǐng)?zhí)枺?/td>: 201010290701.5
• 申請(qǐng)日: 2010-09-21
• 公開(kāi)（公告）號(hào): CN101963921A
• 公開(kāi)（公告）日: 2011-02-02
• 發(fā)明（設(shè)計(jì)）人: 宮建濤;王一峰;胡仲華
• 申請(qǐng)（專(zhuān)利權(quán)）人: 卓望數(shù)碼技術(shù)(深圳)有限公司
• 主分類(lèi)號(hào): G06F9/46
• 分類(lèi)號(hào): G06F9/46;G06F9/50
• 代理公司: 廣州三環(huán)專(zhuān)利代理有限公司 44202
• 代理人: 郝傳鑫;潘中毅

技術(shù)領(lǐng)域

本發(fā)明涉及計(jì)算機(jī)技術(shù)領(lǐng)域，尤其涉及一種作業(yè)調(diào)度方法和系統(tǒng)。

背景技術(shù)

現(xiàn)有的作業(yè)調(diào)度系統(tǒng)大多基于開(kāi)源組件quartz構(gòu)建，Quartz中的觸發(fā)器中，最常用的是SimpleTrigger(簡(jiǎn)單觸發(fā)器)和CronTrigger(時(shí)鐘觸發(fā)器)，本質(zhì)上都是基于時(shí)間的觸發(fā)，雖然用它們也可以實(shí)現(xiàn)較為復(fù)雜的作業(yè)調(diào)度，但是缺少一樣項(xiàng)目中經(jīng)常使用到的關(guān)鍵特性，即作業(yè)調(diào)度除了要滿(mǎn)足時(shí)間條件外還存在一種作業(yè)依賴(lài)關(guān)系，例如B作業(yè)的執(zhí)行需要以A作業(yè)的成功執(zhí)行為條件，現(xiàn)有的作業(yè)調(diào)度系統(tǒng)僅能分別設(shè)定A和B的執(zhí)行開(kāi)始時(shí)間，但當(dāng)A的執(zhí)行過(guò)程超過(guò)預(yù)想值，在B的執(zhí)行開(kāi)始時(shí)間到達(dá)時(shí)A還沒(méi)有執(zhí)行完成，則會(huì)導(dǎo)致B的執(zhí)行時(shí)數(shù)據(jù)不完整甚至發(fā)生錯(cuò)誤。為了避免此類(lèi)現(xiàn)象發(fā)生，使用現(xiàn)有的作業(yè)調(diào)度系統(tǒng)只有將B的執(zhí)行開(kāi)始時(shí)間設(shè)定得盡量晚，給A的執(zhí)行盡可能預(yù)留更多的時(shí)間，這只能盡量減少遇到這種問(wèn)題的機(jī)率，但是無(wú)法根除。

發(fā)明內(nèi)容

本發(fā)明實(shí)施例所要解決的技術(shù)問(wèn)題在于，提供一種作業(yè)調(diào)度方法和系統(tǒng)，可根據(jù)作業(yè)之間的依賴(lài)關(guān)系來(lái)觸發(fā)執(zhí)行作業(yè)。

為了解決上述技術(shù)問(wèn)題，本發(fā)明實(shí)施例提供了一種作業(yè)調(diào)度方法，所述作業(yè)調(diào)度方法包括：

判斷作業(yè)在預(yù)設(shè)的作業(yè)依賴(lài)關(guān)系中的所有父作業(yè)是否均成功執(zhí)行；

當(dāng)所述作業(yè)的所有父作業(yè)均成功執(zhí)行時(shí)，則觸發(fā)執(zhí)行所述作業(yè)。

其中，所述作業(yè)調(diào)度方法還包括：

通過(guò)一張有向無(wú)環(huán)圖設(shè)定作業(yè)的依賴(lài)關(guān)系。

其中，判斷作業(yè)在預(yù)設(shè)的作業(yè)依賴(lài)關(guān)系中的所有父作業(yè)是否均成功執(zhí)行包括：

檢測(cè)所述父作業(yè)的執(zhí)行進(jìn)度，所述執(zhí)行進(jìn)度包括最后一次執(zhí)行成功的時(shí)間值；

判斷所述作業(yè)的所有父作業(yè)的執(zhí)行成功的時(shí)間值是否滿(mǎn)足預(yù)設(shè)條件。

其中，所述作業(yè)調(diào)度方法還包括：

判斷是否到達(dá)所述作業(yè)的定時(shí)觸發(fā)時(shí)間；

當(dāng)?shù)竭_(dá)所述作業(yè)的定時(shí)觸發(fā)時(shí)間，并且所述作業(yè)的所有父作業(yè)均成功執(zhí)行，則觸發(fā)執(zhí)行所述作業(yè)。

其中，所述判斷是否到達(dá)所述作業(yè)的定時(shí)觸發(fā)時(shí)間，當(dāng)判斷結(jié)果為已到達(dá)所述作業(yè)的定時(shí)觸發(fā)時(shí)間后，每隔一定時(shí)間間隔進(jìn)行判斷作業(yè)在預(yù)設(shè)作業(yè)依賴(lài)關(guān)系中所有父作業(yè)的是否均成功執(zhí)行；

當(dāng)所述作業(yè)的所有父作業(yè)均成功執(zhí)行時(shí)，則觸發(fā)執(zhí)行所述作業(yè)。

相應(yīng)地，本發(fā)明實(shí)施例還提供了一種作業(yè)調(diào)度系統(tǒng)，所述作業(yè)調(diào)度系統(tǒng)包括：

作業(yè)流程資源庫(kù)，用于保存作業(yè)流程中各個(gè)作業(yè)之間相互的依賴(lài)關(guān)系；

作業(yè)觸發(fā)引擎，用于判斷作業(yè)在預(yù)設(shè)作業(yè)依賴(lài)關(guān)系中的所有父作業(yè)是否均成功執(zhí)行，當(dāng)所述作業(yè)的所有父作業(yè)均成功執(zhí)行時(shí)，則觸發(fā)執(zhí)行所述作業(yè)；

作業(yè)執(zhí)行插件，用于執(zhí)行所述作業(yè)。

其中，所述作業(yè)調(diào)度系統(tǒng)還包括：

流程設(shè)計(jì)單元，用于通過(guò)一張有向無(wú)環(huán)圖設(shè)定作業(yè)的依賴(lài)關(guān)系。

其中，所述作業(yè)觸發(fā)引擎判斷所述作業(yè)的所有父作業(yè)是否均成功執(zhí)行包括：

檢測(cè)所述父作業(yè)的執(zhí)行進(jìn)度，所述執(zhí)行進(jìn)度包括最后一次執(zhí)行成功的時(shí)間值；

判斷所述作業(yè)的所有父作業(yè)的執(zhí)行成功的時(shí)間值是否滿(mǎn)足預(yù)設(shè)條件。

其中，所述作業(yè)觸發(fā)引擎包括：

父作業(yè)檢測(cè)模塊，用于判斷作業(yè)在預(yù)設(shè)作業(yè)依賴(lài)關(guān)系中所有父作業(yè)的是否均成功執(zhí)行；

定時(shí)模塊，用于判斷是否到達(dá)所述作業(yè)的定時(shí)觸發(fā)時(shí)間；

觸發(fā)模塊，用于當(dāng)所述父作業(yè)檢測(cè)模塊和定時(shí)模塊均得到肯定的判斷結(jié)果時(shí)，觸發(fā)執(zhí)行所述作業(yè)。

其中，所述父作業(yè)檢測(cè)模塊用于當(dāng)所述定時(shí)模塊判斷得到已到達(dá)所述作業(yè)的定時(shí)觸發(fā)時(shí)間后，每隔一定時(shí)間間隔進(jìn)行判斷作業(yè)在預(yù)設(shè)作業(yè)依賴(lài)關(guān)系中所有父作業(yè)的是否均成功執(zhí)行；

所述觸發(fā)模塊用于當(dāng)所述父作業(yè)檢測(cè)模塊判斷得到所述作業(yè)的所有父作業(yè)均成功執(zhí)行時(shí)，則觸發(fā)執(zhí)行所述作業(yè)。

實(shí)施本發(fā)明實(shí)施例，具有如下有益效果：通過(guò)在現(xiàn)有的作業(yè)調(diào)度系統(tǒng)中加入了根據(jù)流程作業(yè)之間的依賴(lài)關(guān)系的觸發(fā)機(jī)制，能夠更加貼合實(shí)際需要的對(duì)作業(yè)執(zhí)行進(jìn)行靈活的安排和調(diào)度。

附圖說(shuō)明

為了更清楚地說(shuō)明本發(fā)明實(shí)施例或現(xiàn)有技術(shù)中的技術(shù)方案，下面將對(duì)實(shí)施例或現(xiàn)有技術(shù)描述中所需要使用的附圖作簡(jiǎn)單地介紹，顯而易見(jiàn)地，下面描述中的附圖僅僅是本發(fā)明的一些實(shí)施例，對(duì)于本領(lǐng)域普通技術(shù)人員來(lái)講，在不付出創(chuàng)造性勞動(dòng)的前提下，還可以根據(jù)這些附圖獲得其他的附圖。

圖1為本發(fā)明實(shí)施例中一種作業(yè)調(diào)度系統(tǒng)的結(jié)構(gòu)組成示意圖；

圖2為本發(fā)明實(shí)施例中的作業(yè)調(diào)度系統(tǒng)中作業(yè)觸發(fā)引擎的結(jié)構(gòu)組成示意圖；

圖3為本發(fā)明實(shí)施例中一種作業(yè)流程的有向無(wú)環(huán)圖；