[發(fā)明專利]通用流程異步調(diào)度方法及系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201310643262.5
• 申請(qǐng)日: 2013-12-03
• 公開(kāi)（公告）號(hào): CN103631594B
• 公開(kāi)（公告）日: 2017-02-15
• 發(fā)明（設(shè)計(jì)）人: 鄭春;陳路凝;王杰飛
• 申請(qǐng)（專利權(quán)）人: 北京宇信科技集團(tuán)股份有限公司
• 主分類號(hào): G06F9/44
• 分類號(hào): G06F9/44
• 代理公司: 北京展翼知識(shí)產(chǎn)權(quán)代理事務(wù)所(特殊普通合伙)11452
• 代理人: 屠長(zhǎng)存

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

本發(fā)明涉及計(jì)算機(jī)軟件領(lǐng)域。更具體地，本發(fā)明涉及通用流程異步調(diào)度方法及系統(tǒng)。

背景技術(shù)

在現(xiàn)有技術(shù)中，在計(jì)算機(jī)系統(tǒng)中的各種應(yīng)用的流程調(diào)度處理，特別是其中的任務(wù)提交處理，均采用同步方式進(jìn)行。具體地，現(xiàn)有流程調(diào)度處理模式一般都是采用單線程處理方式，即，任何流程處理（包括提交處理）全過(guò)程均采用單一線程完成。目前，在計(jì)算機(jī)系統(tǒng)中的各種應(yīng)用的大部分流程調(diào)度中，僅僅能支持單一應(yīng)用的獨(dú)立流程調(diào)度，重要原因就是很難支持高并發(fā)處理能力。然而，實(shí)際中，流程提交處理往往包括大量業(yè)務(wù)判斷、業(yè)務(wù)處理、數(shù)據(jù)持久化等相關(guān)業(yè)務(wù)操作。

在描述現(xiàn)有技術(shù)和本發(fā)明之前，先對(duì)本說(shuō)明書(shū)中的幾個(gè)術(shù)語(yǔ)進(jìn)行描述。

活動(dòng)：活動(dòng)（activity）是流程中的基本的業(yè)務(wù)單元。每一個(gè)活動(dòng)代表一個(gè)特定的業(yè)務(wù)，比如說(shuō)提交、驗(yàn)證等等都可以是一個(gè)活動(dòng)。活動(dòng)有兩種類型：任務(wù)（task）和子處理(sub-process)。任務(wù)很明顯就是單一的活動(dòng)。而子處理是一個(gè)復(fù)合的活動(dòng)，在該活動(dòng)中存在一個(gè)子流程。

作業(yè)：作業(yè)（job）是計(jì)算機(jī)操作者（或是一個(gè)叫做作業(yè)調(diào)度器的程序）交給信息處理系統(tǒng)的執(zhí)行單位。例如執(zhí)行一個(gè)函數(shù)就是一個(gè)作業(yè)。

事件：事件（event）一般對(duì)應(yīng)狀態(tài)的變化。例如按下鍵盤(pán)，這可以作為一種事件。對(duì)于事件的操作一般分為事件的響應(yīng)和事件的處理兩個(gè)部分。

下面描述現(xiàn)有技術(shù)中常見(jiàn)的流程調(diào)度處理。圖1以一個(gè)流程中的提交處理和驗(yàn)證處理為例示出了現(xiàn)有技術(shù)中的常規(guī)流程調(diào)度處理的時(shí)序圖。如圖1所示，在常規(guī)流程調(diào)度處理中，客戶端首先進(jìn)行提交處理，從而進(jìn)入提交活動(dòng)。隨后，進(jìn)行流程狀態(tài)更新并進(jìn)行路由判斷，根據(jù)判斷結(jié)果啟動(dòng)下一活動(dòng)并進(jìn)行與下一活動(dòng)相關(guān)的設(shè)置處理，隨后才返回到客戶端。在此過(guò)程中，客戶端必須等待進(jìn)行路由的判斷、下一活動(dòng)的啟動(dòng)以及相關(guān)的設(shè)置處理。在某些高并發(fā)流程處理的情況下，這樣的等待使得流程處理效率低下。

圖2以一個(gè)流程中的提交和驗(yàn)證為例示出了常規(guī)流程調(diào)度處理的示意圖。如圖2所示，提交的完成與驗(yàn)證的啟動(dòng)這兩個(gè)處理均只能在完整的一個(gè)事務(wù)中順序完成。換句話說(shuō)，提交的活動(dòng)完成這個(gè)處理必須等待驗(yàn)證的活動(dòng)正常啟動(dòng)后，才能結(jié)束。

如圖所示，該流程提交處理方式導(dǎo)致處理響應(yīng)時(shí)間較長(zhǎng)，處理效率受到很大影響。

如上所述，在現(xiàn)有技術(shù)的流程調(diào)度中，流程提交處理隨著流程復(fù)雜度提升、流程路由判斷增多等內(nèi)容，導(dǎo)致流程提交這個(gè)大事務(wù)處理越來(lái)越慢，客戶端響應(yīng)時(shí)間越來(lái)越長(zhǎng)，應(yīng)用系統(tǒng)效率低下。從技術(shù)特征分析而言，導(dǎo)致以上缺點(diǎn)的核心原因是：流程提交從引擎設(shè)計(jì)角度而言，采用一種同步單線程處理的機(jī)制。無(wú)法實(shí)現(xiàn)并行操作。在作為大容量工作流引擎，特別是流程云服務(wù)器能力，對(duì)于并行處理能力要求很高。

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

提出本發(fā)明來(lái)克服現(xiàn)有技術(shù)中的流程調(diào)度效率低下，客戶端響應(yīng)時(shí)間長(zhǎng)的問(wèn)題。本發(fā)明重點(diǎn)在并行處理關(guān)鍵點(diǎn)上，流程處理，尤其是提交處理，實(shí)現(xiàn)可配置的異步處理能力。極大提升流程引擎處理效率和減少處理響應(yīng)時(shí)間。

本發(fā)明的一方面提供一種通用流程異步調(diào)度方法，包括：將與流程對(duì)應(yīng)的進(jìn)程順序地劃分為多個(gè)子進(jìn)程；基于流程狀態(tài)的更新完成所述多個(gè)子進(jìn)程中的一個(gè)子進(jìn)程，而不依賴于所述多個(gè)子進(jìn)程中的下一子進(jìn)程的啟動(dòng)；在所述一個(gè)子進(jìn)程完成時(shí)，通過(guò)流程狀態(tài)的更新啟動(dòng)所述下一子進(jìn)程。

優(yōu)選地，在所述通用流程異步調(diào)度方法中，所述的基于流程狀態(tài)的更新完成所述多個(gè)子進(jìn)程中的一個(gè)子進(jìn)程的步驟包括：在所述一個(gè)子進(jìn)程完成時(shí)，基于更新的流程狀態(tài)返回完成結(jié)果。

優(yōu)選地，在所述通用流程異步調(diào)度方法中，所述的通過(guò)流程狀態(tài)的更新啟動(dòng)所述下一子進(jìn)程的步驟包括：基于更新的流程狀態(tài)產(chǎn)生用于啟動(dòng)下一子進(jìn)程的事件；并且在該事件的觸發(fā)下啟動(dòng)所述下一子進(jìn)程。

優(yōu)選地，在所述通用流程異步調(diào)度方法中，在該事件的觸發(fā)下啟動(dòng)所述下一子進(jìn)程的步驟包括：根據(jù)該事件，產(chǎn)生用于啟動(dòng)下一子進(jìn)程的消息；并且根據(jù)所述消息執(zhí)行下一子進(jìn)程的啟動(dòng)序列。

優(yōu)選地，在所述通用流程異步調(diào)度方法中，所述一個(gè)子進(jìn)程包括從客戶端接收的流程提交子進(jìn)程，基于該流程提交子進(jìn)程的執(zhí)行對(duì)流程狀態(tài)進(jìn)行更新；基于更新的流程狀態(tài)，完成流程提交子進(jìn)程并向客戶端返回結(jié)果。