[發明專利]任務處理方法、裝置及分布式計算機系統

有效

• 申請號: 201810966265.5
• 申請日: 2018-08-23
• 公開（公告）號: CN109308219B
• 公開（公告）日: 2021-08-10
• 發明（設計）人: 魏保子
• 申請（專利權）人: 創新先進技術有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50;G06F9/54
• 代理公司: 北京眾達德權知識產權代理有限公司 11570
• 代理人: 劉杰

本說明書公開了一種任務處理方法、節點及分布式計算機系統，該方法包括：利用事件處理線程池中的線程并行對監聽到的批量即時任務進行過濾處理，并將過濾處理得到的有效即時任務添加至事件隊列；利用業務處理線程池中的線程并行處理事件隊列中的有效即時任務。

技術領域

本說明書涉及計算機領域，尤其涉及一種任務處理方法、裝置及分布式計算機系統。

背景技術

在各種業務場景中均需要進行業務處理，處理用戶側發起的任務請求。所針對的業務場景不同，任務請求的數據也不相同。在某些業務場景：在同一時刻需要處理用戶側大規模發起的任務請求；在某些業務場景，雖然用戶只發起一次請求，但是產生的是需要批量操作的任務請求；在某些業場景，需要定時觸發進行業務處理，如每天的0點或未來的某個時刻需要處理一些業務邏輯。

發明內容

本說明書實施例提供一種任務處理方法、裝置及分布式計算機系統。

第一方面，本說明書實施例提供一種任務處理方法，包括：

監聽批量即時任務，并將監聽到的批量即時任務添加至事件處理線程池；

利用所述事件處理線程池中的線程并行對監聽到的批量即時任務進行過濾處理，并將過濾處理得到的有效即時任務添加至事件隊列；

利用業務處理線程池中的線程并行處理所述事件隊列中的有效即時任務。

第二方面，本說明書實施例提供一種任務處理裝置，包括任務處理器，所述任務處理器包括：

任務監聽器，用于監聽批量即時任務，并將監聽到的批量即時任務添加至事件處理線程池；

核心處理模塊，用于利用所述事件處理線程池中的線程并行對監聽到的批量即時任務進行過濾處理，并將過濾處理得到的有效即時任務添加至事件隊列，利用業務處理線程池中的線程并行處理所述事件隊列中的有效即時任務。

第三方面，本說明書實施例提供一種任務處理節點，包括存儲器、處理器及存儲在存儲器上并可在處理器上運行的計算機程序，所述處理器執行所述程序時實現第一方面任一項所述方法的步驟。

第四方面，本說明書實施例提供一種任務處理方法，應用于分布式計算機系統，所述系統包括多個任務處理節點，所述任務處理節點用于執行第一方面中任一項所述的方法。

第五方面，本說明實施例提供一種分布式計算機系統，包括多個任務處理節點，所述任務節點上布置有第二方面中任一項所述的任務處理裝置。

本說明書實施例提供的一個或者多個實施例，至少實現了如下技術效果或者優點：

由于利用事件處理線程池中的線程并行對監聽到的批量即時任務進行過濾處理，并將過濾處理得到的有效即時任務添加至事件隊列；利用業務處理線程池中的線程并行處理事件隊列中的有效即時任務，從而避免了無效任務對業務處理線程的占用，并且是多個線程并行對有效即時任務進行處理，故而，基于這兩點，使得適用于業務處理實時性要求比較高的場景，進而能夠穩定、快速的批量處理即時任務，實現了處理任務的高吞吐量和秒內延時。

附圖說明

為了更清楚地說明本說明書實施例中的技術方案，下面將對實施例描述中所需要使用的附圖作一簡單地介紹，顯而易見地，下面描述中的附圖是本說明書的一些實施例，對于本領域普通技術人員來講，在不付出創造性勞動的前提下，還可以根據這些附圖獲得其他的附圖。

圖1為本說明書實施例中任務處理方法的場景圖；

圖2為本說明書實施例中任務處理方法的流程圖；

圖3為圖1中任務處理節點的結構示意圖；

圖4為圖1中分布式計算系統的結構圖。

具體實施方式