[發(fā)明專利]一種支持工作流活動(dòng)實(shí)例成批處理執(zhí)行的方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201010184944.0
• 申請(qǐng)日: 2010-05-27
• 公開（公告）號(hào): CN101833712A
• 公開（公告）日: 2010-09-15
• 發(fā)明（設(shè)計(jì)）人: 劉建勛;文一憑;胡錦敏
• 申請(qǐng)（專利權(quán)）人: 湖南科技大學(xué)
• 主分類號(hào): G06Q10/00
• 分類號(hào): G06Q10/00
• 代理公司: 長(zhǎng)沙市融智專利事務(wù)所 43114
• 代理人: 黃美成

1.一種支持工作流活動(dòng)實(shí)例成批處理執(zhí)行的方法，具有工作流引擎的工作流服務(wù)模塊建立在支持成批處理的工作流模型上，其特征在于，工作流服務(wù)模塊包括一個(gè)分組批處理調(diào)度引擎，采用事件觸發(fā)機(jī)制來組織活動(dòng)實(shí)例成批處理的執(zhí)行過程，事件被送入事件隊(duì)列，由分組批處理調(diào)度引擎中的ECA規(guī)則解釋器監(jiān)控事件隊(duì)列，當(dāng)事件隊(duì)列長(zhǎng)度發(fā)生變化，由ECA規(guī)則解釋器對(duì)事件隊(duì)列中的新到事件進(jìn)行處理；所述的ECA規(guī)則解釋器為事件-條件-動(dòng)作規(guī)則解釋器；

所述的事件包括正常事件、緩沖區(qū)長(zhǎng)度低于閾值事件、定時(shí)器事件和執(zhí)行者空閑事件；

所述的正常事件、緩沖區(qū)長(zhǎng)度低于閾值事件、定時(shí)器事件產(chǎn)生過程如下：

步驟1：產(chǎn)生活動(dòng)實(shí)例：工作流引擎檢測(cè)到工作流模型中當(dāng)前要處理的活動(dòng)為可成批處理的工作流活動(dòng)，則產(chǎn)生活動(dòng)實(shí)例并送往分組批處理調(diào)度引擎；

步驟2：由分組批處理調(diào)度引擎中的緩沖區(qū)管理器將接收到的活動(dòng)實(shí)例分配到對(duì)應(yīng)的成批服務(wù)區(qū)緩沖區(qū)，引起成批服務(wù)區(qū)緩沖區(qū)的長(zhǎng)度變化，當(dāng)成批服務(wù)區(qū)緩沖區(qū)的長(zhǎng)度變化達(dá)到預(yù)設(shè)的閾值，則由緩沖區(qū)管理器觸發(fā)正常事件；當(dāng)緩沖區(qū)管理器監(jiān)測(cè)到某一個(gè)成批服務(wù)區(qū)緩沖區(qū)長(zhǎng)度發(fā)生變化但又未達(dá)到預(yù)設(shè)閾值時(shí)，則觸發(fā)緩沖區(qū)長(zhǎng)度低于閾值事件；

緩沖區(qū)長(zhǎng)度低于閾值事件被ECA規(guī)則解釋器解釋完，由分組批處理調(diào)度引擎啟動(dòng)定時(shí)器定時(shí)Δt1時(shí)間，當(dāng)Δt1時(shí)間到，而正常事件沒有被觸發(fā)時(shí)，則由定時(shí)器產(chǎn)生定時(shí)器事件；

執(zhí)行者空閑事件的產(chǎn)生過程為：執(zhí)行者執(zhí)行完，由執(zhí)行者產(chǎn)生執(zhí)行者空閑事件；由執(zhí)行者將該執(zhí)行者空閑事件送入到事件隊(duì)列中；

活動(dòng)實(shí)例與成批服務(wù)區(qū)緩沖區(qū)具有一一對(duì)應(yīng)關(guān)系；

?事件名稱??處理過程?第i個(gè)執(zhí)行者對(duì)應(yīng)的執(zhí)?行者空閑事件??1、將由第i個(gè)成批服務(wù)區(qū)緩沖區(qū)產(chǎn)生的定時(shí)器清??零；??2、清除事件隊(duì)列中與第i個(gè)成批服務(wù)區(qū)緩沖區(qū)有??關(guān)的所有事件；??3、開啟緩沖區(qū)管理器對(duì)第i個(gè)成批服務(wù)區(qū)緩沖區(qū)??監(jiān)控；??4、將ECA規(guī)則解釋器復(fù)位以使下一次調(diào)度得以??進(jìn)行。?來自于第i個(gè)緩沖區(qū)的?定時(shí)器事件??1、關(guān)閉緩沖區(qū)管理器對(duì)第i個(gè)成批服務(wù)區(qū)緩沖區(qū)??監(jiān)控；??2、從第i個(gè)成批服務(wù)區(qū)緩沖區(qū)提取一組符合成批??處理?xiàng)l件的活動(dòng)實(shí)例送給第i個(gè)執(zhí)行者進(jìn)行批處??理；??3、將ECA規(guī)則解釋器復(fù)位以使下一次調(diào)度得以??進(jìn)行；

?事件名稱??處理過程?正常事件(來自于第i?個(gè)緩沖區(qū))??1、關(guān)閉緩沖區(qū)管理器對(duì)第i個(gè)成批服務(wù)區(qū)緩沖區(qū)??監(jiān)控；??2、從第i個(gè)成批服務(wù)區(qū)緩沖區(qū)提取一組符合成批??處理?xiàng)l件的活動(dòng)實(shí)例送給第i個(gè)執(zhí)行者進(jìn)行批處??理；??3.將ECA規(guī)則解釋器復(fù)位以使下一次調(diào)度得以??進(jìn)行；?緩沖區(qū)長(zhǎng)度低于閾值事?件(來自于第i個(gè)緩沖區(qū))??啟動(dòng)定時(shí)器，設(shè)置定時(shí)器的等待時(shí)間為Δt1，定??時(shí)器開始工作。

所述的對(duì)新到事件進(jìn)行處理的過程為根據(jù)上表執(zhí)行處理。