[發明專利]分布式圖計算的方法、裝置、設備及存儲介質

在審

• 申請號: 202010219704.3
• 申請日: 2020-03-25
• 公開（公告）號: CN113448692A
• 公開（公告）日: 2021-09-28
• 發明（設計）人: 趙尚宇;陳哲嘉
• 申請（專利權）人: 杭州海康威視數字技術股份有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46;G06F9/48
• 代理公司: 北京三高永信知識產權代理有限責任公司 11138
• 代理人: 謝冬寒

1.一種分布式圖計算的方法，其特征在于，所述方法應用于第一設備，所述方法包括：

確定所述目標任務的初始子任務；

基于待執行的目標任務的各子任務之間的依賴關系，自所述初始子任務開始執行所述目標任務的各子任務；

當所述目標任務的第一子任務執行完畢時，基于所述依賴關系，確定所述第一子任務下一步的第二子任務，確定所述第二子任務的輸入數據所存儲的第二設備，向所述第二設備發送任務繼續執行通知，其中，所述任務繼續執行通知中攜帶有所述第一子任務的輸出數據和所述第二子任務的標識。

2.根據權利要求1所述的方法，其特征在于，所述基于待執行的目標任務的各子任務之間的依賴關系，確定所述目標任務的至少一個初始子任務之前，所述方法還包括：

對應所述目標任務的各子任務建立輸入緩存隊列和輸出緩存隊列，其中，所述輸出緩存隊列用于緩存所屬子任務的輸出數據，所述輸入緩存隊列用于緩存所屬子任務的上一步的子任務的輸出數據。

3.根據權利要求2所述的方法，其特征在于，所述方法還包括：

當所述目標任務的第三子任務的輸出緩存隊列中緩存的輸出數據的數目達到預設的第一數目閾值時，停止執行所述第三子任務的處理；

當所述目標任務的第三子任務的輸出緩存隊列中緩存的輸出數據的數目小于預設的第一數目閾值時，重新開始執行所述第三子任務的處理。

4.根據權利要求2所述的方法，其特征在于，所述方法還包括：

當所述目標任務的第四子任務的輸入緩存隊列中緩存的輸入數據的數目達到預設的第二數目閾值時，如果第四子任務前一步的第五子任務的輸入數據存儲于第一設備，則停止將所述第五子任務的輸出緩存隊列中的輸出數據向所述第四子任務的輸入緩存隊列轉移，如果第四子任務前一步的第五子任務的輸入數據存儲于第三設備，則向所述第三設備發送停止傳輸通知，其中，所述停止傳輸通知用于指示所述第三設備停止將所述第五子任務的輸出緩存隊列中的輸出數據向所述第一設備傳輸；

當所述目標任務的第四子任務的輸入緩存隊列中緩存的輸入數據的數目小于預設的第二數目閾值時，如果第四子任務前一步的第五子任務的輸入數據存儲于第一設備，則重新開始將所述第五子任務的輸出緩存隊列中的輸出數據向所述第四子任務的輸入緩存隊列轉移，如果第四子任務前一步的第五子任務的輸入數據存儲于第三設備，則向所述第三設備發送啟動傳輸通知，其中，所述啟動傳輸通知用于指示所述第三設備重新開始將所述第五子任務的輸出緩存隊列中的輸出數據向所述第一設備傳輸。

5.根據權利要求2所述的方法，其特征在于，所述方法還包括：

對于所述目標任務的第六子任務，在所述初始子任務開始執行時，啟動預設時長的計時器；

如果在所述計時器的計時時長達到預設時長之前，所述第六子任務的輸出緩存隊列中輸出數據的數據量達到預設的數據量閾值，則如果所述第六子任務的下一步的第七子任務的輸入數據所存儲的第四設備與所述第六子任務的輸出數據所存儲的第五設備相同，則將所述輸出數據移動至所述第七子任務的輸入緩存隊列，如果所述第六子任務的下一步的第七子任務的輸入數據所存儲的第四設備與所述第六子任務的輸出數據所存儲的第五設備不同，則向所述第五設備發送攜帶有所述第六子任務的輸出緩存隊列中輸出數據和所述第七子任務的標識的任務繼續執行通知；

如果在所述計時器的計時時長達到預設時長時，所述第六子任務的輸出緩存隊列中輸出數據的數據量未達到預設的數據量閾值，則如果所述第六子任務的下一步的第七子任務的輸入數據所存儲的第四設備與所述第六子任務的輸出數據所存儲的第五設備相同，則將所述輸出數據移動至所述第七子任務的輸入緩存隊列，如果所述第六子任務的下一步的第七子任務的輸入數據所存儲的第四設備與所述第六子任務的輸出數據所存儲的第五設備不同，則向所述第五設備發送攜帶有所述第六子任務的輸出緩存隊列中輸出數據和所述第七子任務的標識的任務繼續執行通知。