[發(fā)明專利]一種大規(guī)模流程并行排程方法

在審

• 申請?zhí)枺?/td>: 201610343434.0
• 申請日: 2016-05-23
• 公開（公告）號: CN107423028A
• 公開（公告）日: 2017-12-01
• 發(fā)明（設計）人: 袁雪寧;何銘
• 申請（專利權）人: 何銘
• 主分類號: G06F9/38
• 分類號: G06F9/38
• 代理公司: 南京天華專利代理有限責任公司32218
• 代理人: 夏平

技術領域

本發(fā)明涉及到流程管理系統(tǒng)或流程處理系統(tǒng)中的流程排程方法，具體涉及到一種大規(guī)模流程的排程方法。

背景技術

在流程管理系統(tǒng)或流程處理系統(tǒng)中，在設計時，流程設計或管理人員依據需求設計出流程模板(Process Template)存儲于系統(tǒng)中，一個流程模板由一個或多個節(jié)點(Node)構成，每一個節(jié)點模板定義流程中的一個執(zhí)行步驟。在運行時，業(yè)務系統(tǒng)或上游系統(tǒng)按照輸入信息和數據的屬性及關系，將其對應到流程模板上，系統(tǒng)根據該模板創(chuàng)建新的流程實例(Process Instance)，每一筆新的業(yè)務或上游數據都被對應模板并創(chuàng)建一個新的流程實例。流程實例具有與其來源模板一模一樣的節(jié)點和關系，系統(tǒng)按照流程實例的節(jié)點順序和邏輯關系依次向前執(zhí)行直至完成。來自同一個流程模板的所有流程實例，僅流程實例狀態(tài)會有不同(即流程實例上所承載的信息和數據)，其他均相同，流程實例在流程完成之前都稱為流程活動實例。

現有的流程執(zhí)行和處理機制，是將流程活動實例獨立分開、獨立處理、獨立執(zhí)行，是以流程活動實例為單位進行處理執(zhí)行，每個被執(zhí)行的流程活動實例都在獨立的線程(Thread)或偽線程或管線(Pipeline)中被執(zhí)行，例如：在現有機制中，100個需要執(zhí)行的流程活動實例會被分至100個線程中執(zhí)行，或分至10個線程中，每個線程內部以排隊串行的方式依次執(zhí)行流程實例。

現有處理機制的問題是進行大規(guī)模流程作業(yè)或處理時，流程活動實例數量會非常大(十萬級或百萬級)，獨立執(zhí)行的效率低下，每個流程活動實例的單位耗時會隨著流程實例總數的上升而線性增加，查詢、更新等所有訪問操作的性能都會全面下降。同時，現有處理機制導致占用龐大的計算處理資源，通常一 臺常規(guī)服務器瞬時負擔不超過1,000個流程活動實例，那么十萬個流程活動實例就需要上百臺服務器的資源。

發(fā)明內容

本發(fā)明所要解決的技術問題是：提供一種可改變流程處理執(zhí)行的結構和模式、使流程活動實例的處理性能效率與流程活動實例的總數脫鉤、顯著降低在大規(guī)模流程處理上的服務器資源需求、降低流程活動實例數量所帶來的系統(tǒng)并發(fā)沖突的大規(guī)模流程并行排程方法。

為解決上述問題，本發(fā)明采用了一種大規(guī)模流程并行排程方法，每個流程都有若干個模板節(jié)點組成，所述的并行排程方法為：

1)以模板節(jié)點為單位構建處理管線，管線在物理上對應到進程、線程或事件；每一個節(jié)點對應一個管線實例。管線在初始化時提取模板和節(jié)點信息，同時預編譯或加載節(jié)點的執(zhí)行代碼。

2)每個管線獨立持續(xù)地運行，完成所有流程處理計算，管線具有完全相同的處理方法，其具體步驟為：

A)從持久化存儲或流程實例池中查詢提取所有當前節(jié)點為該管線節(jié)點的流

程活動實例，結果為流程活動實例集合。

B)對A步驟中的集合以并行或串行方式循環(huán)，將流程活動實例作為輸入參數，執(zhí)行節(jié)點處理動作，得到該流程活動實例的結果狀態(tài)和輸出數據。同時按照流程模板節(jié)點設定，將該流程活動實例的節(jié)點推進至下一個。

C)在B步驟中循環(huán)處理完畢后，得到對應A步驟集合中的所有流程活動實例的結果狀態(tài)集合和輸出數據集合。

D)管線以批處理方式對C步驟中結果狀態(tài)集合進行一次性更新或存儲，同時以批處理方式對C步驟中輸出數據集合進行一次性寫入或存儲。

E)管線完成本輪處理工作，執(zhí)行事后清理，回到A步驟重復繼續(xù)。

本發(fā)明的有益效果是：本發(fā)明以二維引用表形式用節(jié)點列(Column)作為執(zhí)行入口代替了現有通行的以流程實例作為執(zhí)行入口的處理方式，將現有的橫 向計算處理方式變?yōu)榭v向計算處理方式，解決了在大規(guī)模的流程處理上，流程活動實例數龐大時(如超過1萬個活動實例)，現有通行方法所出現的執(zhí)行效率低下和大量消耗處理資源的問題。

附圖說明

圖1是本發(fā)明所述的并行排程方法的示意圖。

具體實施方式

下面結合附圖，詳細描述本發(fā)明所述的一種大規(guī)模流程并行排程方法的具體實施方案：