[發明專利]任務處理方法、裝置、設備及計算機可讀存儲介質

在審

• 申請號: 202010180590.6
• 申請日: 2020-03-13
• 公開（公告）號: CN111400330A
• 公開（公告）日: 2020-07-10
• 發明（設計）人: 劉建波;黃蔚
• 申請（專利權）人: 深圳前海微眾銀行股份有限公司
• 主分類號: G06F16/23
• 分類號: G06F16/23;G06F9/52
• 代理公司: 深圳市世紀恒程知識產權代理事務所 44287
• 代理人: 王韜

1.一種任務處理方法，其特征在于，所述任務處理方法包括：

每隔第一預設時間通過輪詢線程開啟第一事務；

向目標數據庫發送查詢命令，得到第一返回結果，并根據所述第一返回結果判斷是否存在指定類型且處于空閑狀態的互斥鎖；

若存在指定類型且處于空閑狀態的互斥鎖，則向所述目標數據庫發送第一更新命令，得到第二返回結果，并根據所述第二返回結果判斷所述互斥鎖是否已被鎖定；

若判定所述互斥鎖未被鎖定，則向所述目標數據庫提交所述第一事務，以競爭獲取互斥鎖，并進行任務處理。

2.如權利要求1所述的任務處理方法，其特征在于，所述每隔第一預設時間通過輪詢線程開啟第一事務的步驟包括：

每隔第一預設時間獲取輪詢線程的上下文信息，并根據所述上下文信息判斷所述輪詢線程中是否存在處理事務；

若所述輪詢線程中存在處理事務，則通過所述輪詢線程創建第一同步等待線程，并在所述第一同步等待線程中開啟第一事務；

若所述輪詢線程中不存在處理事務，則在所述輪詢線程中開啟第一事務。

3.如權利要求1所述的任務處理方法，其特征在于，所述任務處理方法還包括：

當偵測到所述第一事務提交成功、獲取到互斥鎖時，在所述輪詢線程中開啟第二事務；

通過所述輪詢線程查詢任務列表，得到待執行任務；

對所述待執行任務進行標記，并將標記后的待執行任務提交到線程池進行處理；

當偵測到任務處理完成時，向所述目標數據庫提交所述第二事務。

4.如權利要求3所述的任務處理方法，其特征在于，所述當偵測到任務處理完成時，向所述目標數據庫提交所述第二事務的步驟之后，還包括：

通過所述輪詢線程開啟第三事務；

向所述目標數據庫發送第二更新命令，以釋放所述互斥鎖，并向所述目標數據庫提交所述第三事務。

5.如權利要求4所述的任務處理方法，其特征在于，所述通過所述輪詢線程開啟第三事務的步驟包括：

獲取所述輪詢線程的上下文信息，并根據所述上下文信息判斷所述輪詢線程中是否存在處理事務；

若所述輪詢線程中存在處理事務，則通過所述輪詢線程創建第二同步等待線程，并在所述第二同步等待線程中開啟第三事務；

若所述輪詢線程中不存在處理事務，則在所述輪詢線程中開啟第三事務。

6.如權利要求1至5中任一項所述的任務處理方法，其特征在于，所述任務處理方法還包括：

當根據所述第一返回結果判定不存在指定類型且處于空閑狀態的互斥鎖時，或當根據所述第二返回結果判定所述互斥鎖已被鎖定時，或當偵測到所述第一事務提交失敗時，記錄互斥鎖獲取失敗的信息，并在經過第二預設時間時返回執行步驟：向目標數據庫發送查詢命令，得到第一返回結果，并根據所述第一返回結果判斷是否存在指定類型且處于空閑狀態的互斥鎖。

7.如權利要求6所述的任務處理方法，其特征在于，所述失敗的信息中包括第一返回結果信息，所述任務處理方法還包括：

判斷所述失敗的信息的數量是否超過預設閾值；

若超過預設閾值，則根據所述第一返回結果信息判斷各第一返回結果是否均為空；

若各第一返回結果均為空，則向所述目標數據庫發送第三更新命令，以強制釋放所述互斥鎖。

8.一種任務處理裝置，其特征在于，所述任務處理裝置包括：

第一開啟模塊，用于每隔第一預設時間通過輪詢線程開啟第一事務；

第一判斷模塊，用于向目標數據庫發送查詢命令，得到第一返回結果，并根據所述第一返回結果判斷是否存在指定類型且處于空閑狀態的互斥鎖；

第二判斷模塊，用于若存在指定類型且處于空閑狀態的互斥鎖，則向所述目標數據庫發送第一更新命令，得到第二返回結果，并根據所述第二返回結果判斷所述互斥鎖是否已被鎖定；

互斥鎖競爭模塊，用于若判定所述互斥鎖未被鎖定，則向所述目標數據庫提交所述第一事務，以競爭獲取互斥鎖，并進行任務處理。