[發明專利]批量調度系統及方法

有效

• 申請號: 201110391457.6
• 申請日: 2011-11-30
• 公開（公告）號: CN102393822A
• 公開（公告）日: 2012-03-28
• 發明（設計）人: 鄒長龍;鄒幫山;魯志彬;王凱
• 申請（專利權）人: 中國工商銀行股份有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46;G06Q40/04
• 代理公司: 中科專利商標代理有限責任公司 11021
• 代理人: 宋焰琴

1.一種批量調度系統，該系統包括：

參數設置裝置(100)，用戶通過該裝置設置系統參數和任務處理相關參數，并將設置的參數存儲到數據存儲裝置(600)中；

預處理裝置(300)，用于對批量任務進行預處理，并將處理后產生的任務輸出到數據存儲裝置(600)中；

調度引擎裝置(400)，用于定時偵測系統當前并發處理任務量，計算系統可分配的處理各渠道上送批量任務的線程數，并將結果輸出給任務處理裝置(500)；

任務處理裝置(500)，用于接收從調度引擎裝置(400)傳輸過來的批量任務處理線程數，調整內部線程，根據任務優先次序參數，讀取經過預處理后的任務，進行任務處理；

數據存儲裝置(600)，用于接收并存儲參數設置裝置(100)設置或計算得到的參數、各渠道上送的批量任務以及預處理裝置(300)生成的任務和任務處理日志。

2.如權利要求1所述的系統，其特征在于，該系統進一步包括：

任務數據分析裝置(200)，用于記錄與任務量相關的信息，計算某一時段內的渠道特征值和時點特征值，并將計算結果存儲在數據存儲裝置(600)中。

3.如權利要求2所述的系統，其特征在于，所述調度引擎裝置(400)根據從數據存儲裝置(600)中獲取系統最大并發處理任務量、當前時段的渠道特征值和時點特征值，計算可分配的處理各渠道上送批量任務的線程數。

4.如權利要求3所述的系統，其特征在于，所述調度引擎裝置(400)進一步包括：

任務量偵測單元(401)，按照預先設定的時間間隔，定時獲取所述系統當前并發處理任務量N，輸出給調度決策單元(403)，其中N是自然數；

調度決策單元(403)，從系統參數設置單元(101)讀取系統最大并發處理任務量M，計算M是否大于N，如果大于，則計算當前時段系統能夠分配給各渠道上傳的批量任務的處理線程數T，其中M和T為自然數。

5.如權利要求4所述的系統，其特征在于，任務處理裝置(500)進一步包括：

線程控制單元(501)，將系統可分配給各渠道上傳的批量任務的處理線程數T與處理任務量N所需的處理線程數進行比較，如果比較結果為T大，則增加線程，并啟動應增加的線程，如果T小，則減少線程，并標記多余線程，待其當前任務完成后釋放該線程；

任務接收單元(502)獲取任務優先次序參數，根據優先級高低順序，讀取T條任務；

任務處理單元(503)，根據讀取順序處理所述任務。

6.如權利要求1～5任一項所述的系統，其特征在于，系統可分配給各渠道上傳的批量任務的處理線程數T通過以下公式計算：

T＝(M-N)×Pa×Pb，

其中M表示系統最大并發處理任務量，N表示系統當前并發處理任務量，

Pa＝SUM(Sa)/SUM(S)，Pa表示渠道特征值，是指在歷史的某一個時段，某渠道向所述系統上送任務量占所述系統收到的所有任務量的占比，Sa表示某一天，某一時段內某一渠道提交的任務數，SUM(Sa)表示一年內，所述時段內所述渠道提交的任務總數，S表示上述某一天，某一時段內所述系統收到的全部任務數，，SUM(S)表示一年內，所述時段內所述系統收到的任務總數，Pb＝SUM(Sb)/SUM(S)，Pb表示時點特征值，是指在歷史的某一個時段，所述系統接收到的批量任務在所述系統接收到的全部任務中的占比，Sb表示某一天，某一時段內所述系統接收的批量任務數，SUM(Sb)表示一年內，所述時段內所述系統接收的批量任務總數，S表示所述某一天，某一時段內所述系統收到的全部任務數，SUM(S)表示一年內，所述時段內所述系統收到的任務總數。

7.如權利要求6所述的系統，其特征在于，參數設置裝置(100)進一步包括：

系統參數設置單元(101)，用戶通過此單元設置所述系統最大并發處理交易任務量M，設置掃描系統實時并發交易任務量的時間間隔，輸出到數據存儲裝置(600)中；

任務優先次序規則參數設置單元(102)，用戶通過此單元設置不同任務類型的處理優先級次序，輸出到數據存儲裝置(600)中；

任務預處理規則參數設置單元(103)，用戶通過此單元設置所述系統在接收到一個批量任務時所需要做的預處理工作，輸出到數據存儲裝置(600)中。