任務排程檢查方法、裝置、計算機設備和存儲介質與流程

2024-04-15 15:20:05

1.本技術涉及任務調度領域，特別是涉及一種任務排程檢查方法、裝置、計算機設備和存儲介質。


背景技術：

2.隨著計算機技術的發展，出現了分布式任務調度系統，分布式任務調度系統產生每日要執行的任務，安排任務的執行計劃並觸發任務運行。為保證以上內容正確執行，需要對任務排程進行檢查。
3.傳統技術中，一般只檢查任務之間的依賴關係，從而導致任務之間相互等待的情況經常出現，甚至由於長時間等待引起任務中斷，降低了任務執行的效率。
4.因此，如何對任務排程進行檢查提高任務執行的效率是目前亟需解決的問題。


技術實現要素：

5.基於此，有必要針對上述技術問題，提供一種能夠提高任務執行的效率的任務排程檢查方法、裝置、計算機設備、計算機可讀存儲介質和電腦程式產品。
6.第一方面，本技術提供了一種任務排程檢查方法。所述方法包括：
7.確定作業流程中的多個任務，並確定每個任務的任務定義信息；
8.根據每個任務的任務定義信息中的任務依賴關係生成任務圖；所述任務圖中包括多個任務流；
9.基於所述任務圖對各個任務流分別進行有向無環圖校驗；
10.為通過有向無環圖校驗的任務流的目標節點添加任務執行信息；所述任務執行信息包括執行任務所需的作業文件、以及任務執行時間；
11.根據預先配置的衝突規則和所述任務執行信息，對各任務流的目標節點進行衝突校驗，並根據衝突校驗結果得到任務排程檢查結果。
12.在其中一個實施例中，所述任務圖包括鄰接矩陣，所述根據每個任務的任務定義信息中的任務依賴關係生成任務圖，包括：
13.基於所述多個任務的數量構建初始矩陣，所述初始矩陣的每一行對應一個任務，所述初始矩陣的每一列對應一個任務；
14.對於所述初始矩陣中的當前元素，根據所述當前元素所在行對應的任務、以及所述當前元素所在列對應的任務之間的任務依賴關係，確定當前元素的值；所述當前元素為所述初始矩陣中的任一個元素；
15.根據各個元素的值，得到鄰接矩陣。
16.在其中一個實施例中，所述任務圖包括鄰接鍊表，所述根據每個任務的任務定義信息中的任務依賴關係生成任務圖，包括：
17.生成與各個任務分別對應的連結點；
18.遍歷各連結點，並根據所述任務定義信息中的任務依賴關係，對具有依賴關係的
任務所對應的連結點之間增加連結關係，得到鄰接鍊表。
19.在其中一個實施例中，所述基於所述任務圖對各個任務流分別進行有向無環圖校驗，包括：
20.遍歷所述任務圖中的各節點並進行拓撲排序，得到與各個任務流對應的任務執行鍊表；
21.對所述任務執行鍊表進行是否成環校驗，若不成環則確定相應的任務流通過有向無環圖校驗。
22.在其中一個實施例中，所述根據預先配置的衝突規則和所述任務執行信息，對各任務流的目標節點進行衝突校驗，包括：
23.根據預先配置的衝突規則和所述任務執行信息，對各任務流的目標節點的執行時間進行時間衝突校驗；
24.確定所述目標節點中執行時間存在衝突的節點，並判斷每個執行時間存在衝突的節點所需的作業文件是否相同，若相同則基於每個執行時間存在衝突的節點所需的作用文件進行資源衝突校驗。
25.在其中一個實施例中，執行時間存在衝突包括執行時間重合，所述基於每個執行時間存在衝突的節點所需的作用文件進行資源衝突校驗，包括：
26.對於執行時間重合的節點所需的相同的作業文件，若同時存在寫操作，則確定存在資源衝突；
27.對於執行時間重合的節點所需的相同的作業文件，若同時存在寫操作和讀操作，則確定存在資源衝突。
28.在其中一個實施例中，所述執行時間存在衝突包括執行時間間隔小於預設間隔，所述基於每個執行時間存在衝突的節點所需的作用文件進行資源衝突校驗，包括：
29.對於執行時間間隔小於預設間隔的節點所需的相同的作業文件，若同時存在寫操作，則確定存在資源衝突；
30.對於執行時間間隔小於預設間隔的節點所需的相同的作業文件，若同時存在寫操作和讀操作，則確定存在資源衝突。
31.第二方面，本技術還提供了一種任務排程檢查裝置。所述裝置包括：
32.確定模塊，用於確定作業流程中的多個任務，並確定每個任務的任務定義信息；
33.生成模塊，用於根據每個任務的任務定義信息中的任務依賴關係生成任務圖；所述任務圖中包括多個任務流；
34.第一校驗模塊，用於基於所述任務圖對各個任務流分別進行有向無環圖校驗；
35.添加模塊，用於為通過有向無環圖校驗的任務流的目標節點添加任務執行信息；所述任務執行信息包括執行任務所需的作業文件、以及任務執行時間；
36.第二校驗模塊，用於根據預先配置的衝突規則和所述任務執行信息，對各任務流的目標節點進行衝突校驗，並根據衝突校驗結果得到任務排程檢查結果。
37.第三方面，本技術還提供了一種計算機設備。所述計算機設備包括存儲器和處理器，所述存儲器存儲有電腦程式，所述處理器執行所述電腦程式時實現以下步驟：
38.確定作業流程中的多個任務，並確定每個任務的任務定義信息；
39.根據每個任務的任務定義信息中的任務依賴關係生成任務圖；所述任務圖中包括
多個任務流；
40.基於所述任務圖對各個任務流分別進行有向無環圖校驗；
41.為通過有向無環圖校驗的任務流的目標節點添加任務執行信息；所述任務執行信息包括執行任務所需的作業文件、以及任務執行時間；
42.根據預先配置的衝突規則和所述任務執行信息，對各任務流的目標節點進行衝突校驗，並根據衝突校驗結果得到任務排程檢查結果。
43.第四方面，本技術還提供了一種計算機可讀存儲介質。所述計算機可讀存儲介質，其上存儲有電腦程式，所述電腦程式被處理器執行時實現以下步驟：
44.確定作業流程中的多個任務，並確定每個任務的任務定義信息；
45.根據每個任務的任務定義信息中的任務依賴關係生成任務圖；所述任務圖中包括多個任務流；
46.基於所述任務圖對各個任務流分別進行有向無環圖校驗；
47.為通過有向無環圖校驗的任務流的目標節點添加任務執行信息；所述任務執行信息包括執行任務所需的作業文件、以及任務執行時間；
48.根據預先配置的衝突規則和所述任務執行信息，對各任務流的目標節點進行衝突校驗，並根據衝突校驗結果得到任務排程檢查結果。
49.第五方面，本技術還提供了一種電腦程式產品。所述電腦程式產品，包括電腦程式，該電腦程式被處理器執行時實現以下步驟：
50.確定作業流程中的多個任務，並確定每個任務的任務定義信息；
51.根據每個任務的任務定義信息中的任務依賴關係生成任務圖；所述任務圖中包括多個任務流；
52.基於所述任務圖對各個任務流分別進行有向無環圖校驗；
53.為通過有向無環圖校驗的任務流的目標節點添加任務執行信息；所述任務執行信息包括執行任務所需的作業文件、以及任務執行時間；
54.根據預先配置的衝突規則和所述任務執行信息，對各任務流的目標節點進行衝突校驗，並根據衝突校驗結果得到任務排程檢查結果。
55.上述任務排程檢查方法、裝置、計算機設備、存儲介質和電腦程式產品，首先通過確定作業流程中的多個任務以及每個任務的任務定義信息，並根據每個任務的任務定義信息中的任務依賴關係生成任務圖，其次，基於任務圖對各個任務流分別進行有向無環圖校驗，若任務流通過有向無環圖校驗，則為通過有向無環圖校驗的任務流的目標節點添加任務執行信息，任務執行信息包括執行任務所需的作業文件、以及任務執行時間，進而根據預先配置的衝突規則和任務執行信息，對各任務流的目標節點進行衝突校驗，最後根據衝突校驗結果得到任務排程檢查結果。這樣，通過對各任務流的目標節點進行衝突校驗能夠有效防止執行任務時爭搶資源，避免由此引起的任務相互等待、任務中斷等情況，從而提高任務執行的效率。
附圖說明
56.圖1為一個實施例中任務排程檢查方法的應用環境圖；
57.圖2為一個實施例中任務排程檢查方法的流程示意圖；
58.圖3為一個實施例中作業流程圖；
59.圖4為一個實施例中的鄰接矩陣的示意圖；
60.圖5為一個實施例中的鄰接鍊表的示意圖；
61.圖6為一個實施例中衝突校驗的流程示意圖；
62.圖7為另一個實施例中任務排程檢查方法的流程示意圖；
63.圖8為一個實施例中任務排程檢查裝置的結構框圖；
64.圖9為一個實施例中計算機設備的內部結構圖。
具體實施方式
65.為了使本技術的目的、技術方案及優點更加清楚明白，以下結合附圖及實施例，對本技術進行進一步詳細說明。應當理解，此處描述的具體實施例僅僅用以解釋本技術，並不用於限定本技術。
66.需要說明的是，本技術所使用的術語「包括」、「包含」、「具有」以及它們的任何變形，意圖在於覆蓋不排他的包含。例如，包含了一系列步驟或裝置的過程、方法、產品或設備不必限於已清楚地列出的步驟，而是還可以包括沒有清楚地列出的或對於這些過程、方法、產品或設備固有的其它步驟或裝置。本技術所使用的術語「和/或」包括一個或多個相關的所列項目的任意的和所有的組合。
67.此外，本技術所使用的術語「第一」、「第二」等是用於對類似的對象作出命名上的區分，但這些對象本身不受這些術語限制。應當理解，在不脫離本技術的範圍的情況下，這些術語在適當的情況下可以互換。例如，可將「第一校驗模塊」描述為「第二校驗模塊」，且類似地，將「第二校驗模塊」描述為「第一校驗模塊」。
68.本技術實施例提供的任務排程檢查方法，可以應用於如圖1所示的應用環境中。其中，終端102通過網絡與伺服器104進行通信。數據存儲系統可以存儲伺服器104需要處理的數據。數據存儲系統可以集成在伺服器104上，也可以放在雲上或其他網絡伺服器上。本技術可通過終端或伺服器單獨執行實施，也可通過終端和伺服器協同執行實施。比如，工作人員通過終端102制定作業流程，並根據作業流程填寫任務定義信息，終端102將工作流程和任務定義信息發送至伺服器104，伺服器104確定作業流程中的多個任務以及每個任務的任務定義信息，並根據每個任務的任務定義信息中的任務依賴關係生成任務圖，進而基於任務圖對各個任務流分別進行有向無環圖校驗，若任務流通過有向無環圖校驗，則通過終端102為通過有向無環圖校驗的任務流的目標節點添加任務執行信息，任務執行信息包括執行任務所需的作業文件、以及任務執行時間，進而根據預先配置的衝突規則和任務執行信息，對各任務流的目標節點進行衝突校驗，最後根據衝突校驗結果得到任務排程檢查結果。這樣，通過對各任務流的目標節點進行衝突校驗能夠有效防止執行任務時爭搶資源，避免由此引起的任務相互等待、任務中斷等情況，從而提高任務執行的效率。其中，終端102可以但不限於是各種個人計算機、筆記本電腦、智慧型手機、平板電腦等。伺服器104可以用獨立的伺服器或者是多個伺服器組成的伺服器集群來實現。
69.在一個實施例中，如圖2所示，提供了一種任務排程檢查方法，以該方法應用於圖1中的伺服器為例進行說明，包括以下步驟：
70.步驟202，確定作業流程中的多個任務，並確定每個任務的任務定義信息。
71.其中，作業流程描述伺服器執行任務的過程，作業流程由若干個任務以及各個任務之間的執行順序構成。任務定義信息是用來描述任務定義以及任務依賴關係的信息，一般包括任務名稱、任務的提交方式以及任務的前項。任務的提交方式包括自動和依賴。對於提交方式為依賴的任務，所依賴的對象任務就是該任務的前項。通過任務的提交方式和任務的前項可以確定任務依賴關係。
72.具體地，工作人員通過終端制定作業流程，並根據作業流程填寫每個任務的任務定義信息，進而控制將制定完畢的作業流程發送至伺服器。伺服器接收到製作完畢的作業流程，確定作業流程中的多個任務以及每個任務的任務定義信息。例如圖3所示的作業流程中包括4個任務：任務1、任務2、任務3和任務4，任務1完成後執行任務2和任務3，任務2和任務3完成後執行任務4。對應的，任務1、任務2、任務3和任務4的任務定義信息如表1所示：
73.表1任務定義信息
74.任務名稱提交方式前項11-自動無23-依賴133-依賴143-依賴2、3
75.其中，任務1是任務2和任務3的前項，任務2和任務3依賴於任務1，任務2和任務3是任務4的前項，任務4依賴於任務2和任務3，任務2和任務3是並發的。
76.步驟204，根據每個任務的任務定義信息中的任務依賴關係生成任務圖；任務圖中包括多個任務流。
77.其中，任務圖是用節點表示任務的數據結構，任務圖中包括多個節點，每個節點表示一個任務，多個具有依賴關係的任務構成一個任務流。
78.具體地，伺服器確定作業流程中的多個任務以及每個任務的任務定義信息之後，根據每個任務的任務定義信息中的任務依賴關係生成任務圖。由於多個任務的前項可以相同，則任務圖中可以包括多個任務流。需要說明的是，前項相同的任務是並發的。
79.步驟206，基於任務圖對各個任務流分別進行有向無環圖校驗。
80.其中，有向無環圖校驗是校驗任務圖中的任務流是否成環。
81.具體地，伺服器根據每個任務的任務定義信息中的任務依賴關係生成任務圖之後，基於任務圖對各個任務流分別進行有向無環圖校驗，以確定每個任務流是否成環。如果任務流不成環，則該任務流通過有向無環圖校驗。
82.在其中一個實施例中，基於任務圖對各個任務流分別進行有向無環圖校驗，包括：遍歷任務圖中的各節點並進行拓撲排序，得到與各個任務流對應的任務執行鍊表；對任務執行鍊表進行是否成環校驗，若不成環則確定相應的任務流通過有向無環圖校驗。
83.具體地，伺服器生成任務圖之後，遍歷任務圖中的各節點，並根據各節點對應的任務之間的依賴關係進行拓撲排序。需要說明的是，伺服器可以採用廣度優先的方式遍歷任務圖的各節點，也可以採用深度優先的方式遍歷任務圖的各節點，本技術實施例對此不作限定。進而伺服器根據拓撲排序結果得到與各個任務流對應的任務執行鍊表，並對得到的任務執行鍊表進行是否成環校驗，以確定各個任務流是否成環。若不成環則確定相應的任務流通過有向無環圖校驗。若成環，則向終端輸出任務排程檢查結果。
84.本實施例中，遍歷任務圖中的各節點並進行拓撲排序，得到與各個任務流對應的任務執行鍊表；對任務執行鍊表進行是否成環校驗，若不成環則確定相應的任務流通過有向無環圖校驗。這樣，可以對任務排程進行有向無環圖的校驗，避免各個任務之間根據依賴關係出現成環而無法生成執行計劃的現象，從而提高了任務執行的效率。
85.步驟208，為通過有向無環圖校驗的任務流的目標節點添加任務執行信息；任務執行信息包括執行任務所需的作業文件、以及任務執行時間。
86.其中，目標節點是通過有向無環圖校驗的任務流中的任一個節點。
87.具體地，伺服器通過對任務圖進行校驗，確定了通過有向無環圖校驗的任務流之後，通過終端可以為通過有向無環圖校驗的任務流的目標節點添加任務執行信息，所添加的任務執行信息包括執行目標節點對應的任務所需的作業文件以及該任務的執行時間。需要說明的是，執行任務所需的文件可以是文件、也可以是表；任務執行時間包括該任務的開始執行時間與執行結束時間。
88.例如，如表2所示，對表1中的任務1、任務2、任務3以及任務4添加開始執行時間、執行結束時間、執行任務所需的作業文件，以及對所需的作業文件進行的操作(讀操作或寫操作)：
89.表2任務執行信息
[0090][0091]
步驟210，根據預先配置的衝突規則和任務執行信息，對各任務流的目標節點進行衝突校驗，並根據衝突校驗結果得到任務排程檢查結果。
[0092]
其中，衝突規則是校驗各個任務之間是否存在執行衝突的規則，通常預先配置在伺服器中。
[0093]
具體地，通過有向無環圖檢驗的任務流的各個節點的任務執行信息添加完畢之後，伺服器根據預先配置的衝突規則和任務執行信息，對各任務流中的目標節點進行校驗，以確定各任務流中的每個節點在執行對應的任務時是否會存在衝突。校驗的對象包括各任務流的目標節點的執行時間以及執行任務所需的作業文件。進而根據衝突校驗的結果得到任務排程檢查結果，任務排程檢查結果中包括存在衝突的任務名稱以及衝突規則集合。
[0094]
在其中一個實施例中，根據如表3所示的預先配置的衝突規則對表2中所示的任務1、任務2、任務3、任務4進行衝突校驗。可以發現，任務2和任務3均在0點20分01秒對文件2進行讀操作，對文件3進行寫操作，對表3進行寫操作。根據該校驗結果，可以向終端輸出表4所示的任務排程檢查結果，即，對任務2而言，由於任務3與任務2存在執行時間重合，根據衝突規則2和衝突規則3，可以確定任務3與任務2衝突；對任務3而言，由於任務2與任務3存在執行時間重合，根據衝突規則2和衝突規則3，可以確定任務2與任務3衝突。
[0095]
表3衝突規則
[0096][0097]
表4任務排程檢查結果
[0098]
任務名稱2衝突任務名稱3衝突規則集合規則2、規則3任務名稱3衝突任務名稱2衝突規則集合規則2、規則3
[0099]
上述任務排程方法中，首先通過確定作業流程中的多個任務以及每個任務的任務定義信息，並根據每個任務的任務定義信息中的任務依賴關係生成任務圖，其次，基於任務圖對各個任務流分別進行有向無環圖校驗，若任務流通過有向無環圖校驗，則為通過有向無環圖校驗的任務流的目標節點添加任務執行信息，任務執行信息包括執行任務所需的作業文件、以及任務執行時間，進而根據預先配置的衝突規則和任務執行信息，對各任務流的目標節點進行衝突校驗，最後根據衝突校驗結果得到任務排程檢查結果。這樣，通過對各任務流的目標節點進行衝突校驗能夠有效防止執行任務時爭搶資源，避免由此引起的任務相互等待、任務中斷等情況，從而提高任務執行的效率。
[0100]
在其中一個實施例中，任務圖包括鄰接矩陣，根據每個任務的任務定義信息中的任務依賴關係生成任務圖，包括：基於多個任務的數量構建初始矩陣，初始矩陣的每一行對應一個任務，初始矩陣的每一列對應一個任務；對於初始矩陣中的當前元素，根據當前元素所在行對應的任務、以及當前元素所在列對應的任務之間的任務依賴關係，確定當前元素的值；當前元素為初始矩陣中的任一個元素；根據各個元素的值，得到鄰接矩陣。
[0101]
其中，鄰接矩陣是一種通過矩陣表示任務之間依賴關係的數據結構，鄰接矩陣底層為二維數據。
[0102]
具體地，伺服器確定作業流程中的多個任務以及每個任務的任務定義信息之後，基於多個任務的數量構建一個初始矩陣，初始矩陣的每一行對應一個任務，初始矩陣的每一列對應一個任務。例如，對於圖3中所述的作業流程，可以基於4個任務構建一個4
×
4的初始矩陣，4行分別對應任務1、任務2、任務3和任務4，4列分別對應任務1、任務2、任務3和任務4。對於初始矩陣中的當前元素，根據當前元素所在行對應的任務、以及當前元素所在列對應的任務之間的任務依賴關係，確定當前元素的值。例如對於第1行第2列的元素，所在行對應的任務為任務1，所在列對應的任務為任務2，根據任務1和任務2的任務定義信息中的任務依賴關係，若任務2依賴於任務1，則第1行第2列的元素可以確定為1，若任務2和任務1之
間沒有依賴關係，則第1行第2列的元素可以確定為0。需要說明的是，當前元素可以是初始矩陣中的任一個元素，這樣，根據當前元素所在行對應的任務、以及當前元素所在列對應的任務之間的任務依賴關係，就可以確定初始矩陣中各個元素的值，進而得到如圖4所示的鄰接矩陣的示意圖。
[0103]
本實施例中，基於多個任務的數量構建初始矩陣，初始矩陣的每一行對應一個任務，初始矩陣的每一列對應一個任務，對於初始矩陣中的當前元素，根據當前元素所在行對應的任務、以及當前元素所在列對應的任務之間的任務依賴關係，確定當前元素的值，當前元素為初始矩陣中的任一個元素，進而根據各個元素的值，得到鄰接矩陣。這樣，以鄰接矩陣的方式表示任務圖，可以方便地對任務圖進行有向無環圖的校驗，提高任務排程檢查的效率，從而提高任務執行的效率。
[0104]
在其中一個實施例中，任務圖還包括鄰接鍊表，根據每個任務的任務定義信息中的任務依賴關係生成任務圖，包括：生成與各個任務分別對應的連結點；遍歷各連結點，並根據任務定義信息中的任務依賴關係，對具有依賴關係的任務所對應的連結點之間增加連結關係，得到鄰接鍊表。
[0105]
其中，鄰接鍊表是一種通過鍊表的方式表示任務依賴關係的數據結構。
[0106]
具體地，伺服器確定作業流程中的多個任務以及每個任務的任務定義信息之後，生成與各個任務分別對應的連結點。遍歷各連結點，根據各連結點對應的任務的任務定義信息中的任務依賴關係，確定當前連結點的前項任務對應的連結點，進而在對應前項的連結點上增加連結關係，當前連結點可以是任一個與各個任務分別對應的連結點。通過對具有依賴關係的任務所對應的連結點之間增加連結關係，就能得到鄰接鍊表。例如，對於圖3中所述的作業流程，伺服器可以生成與任務1、任務2、任務4以及任務4分別對應的連結點1、連結點2、連結點3以及連結點4。遍歷連結點1、連結點2、連結點3以及連結點4，若連結點2依賴於連結點1，則在連結點1上增加與連結2的連結關係；若連結點3也依賴於連結點1，則在連結點1上增加與連結3的連結關係，直至連結點1、連結點2、連結點3以及連結點4遍歷完畢，得到如圖5所示的鄰接鍊表的示意圖。
[0107]
本實施例中，生成與各個任務分別對應的連結點；遍歷各連結點，並根據任務定義信息中的任務依賴關係，對具有依賴關係的任務所對應的連結點之間增加連結關係，得到鄰接鍊表。這樣，以鄰接鍊表的方式表示任務圖，可以方便地對任務圖進行有向無環圖的校驗，提高任務排程檢查的效率，從而提高任務執行的效率。
[0108]
在其中一個實施例中，如圖6所示，根據預先配置的衝突規則和任務執行信息，對各任務流的目標節點進行衝突校驗，包括：
[0109]
步驟602，根據預先配置的衝突規則和任務執行信息，對各任務流的目標節點的執行時間進行時間衝突校驗。
[0110]
具體地，伺服器根據預先配置的衝突規則和任務執行信息，對各任務流中的目標節點進行校驗時，首先確定各任務流的目標節點的執行時間，對各任務流的目標節點的執行時間進行校驗，以判斷在各任務流中，是否存在執行時間相衝突的節點。
[0111]
步驟604，確定目標節點中執行時間存在衝突的節點，並判斷每個執行時間存在衝突的節點所需的作業文件是否相同，若相同則基於每個執行時間存在衝突的節點所需的作用文件進行資源衝突校驗。
[0112]
具體地，當伺服器對各任務流的目標節點的執行時間進行時間衝突校驗，並確定存在執行時間衝突的節點之後，對於執行時間存在衝突的節點，需要進一步確定存在執行時間衝突的節點執行任務時所需的作業文件是否相同，若存在執行時間衝突的節點執行任務時所需的作業文件相同，則對每個執行時間存在衝突的節點所需的作用文件進行資源衝突校驗。需要說明的是，存在執行時間衝突的節點，可能是各任務流中的任兩個目標節點，也可能是大於兩個的目標節點。
[0113]
本實施例中，根據預先配置的衝突規則和任務執行信息，對各任務流的目標節點的執行時間先進行時間衝突校驗，確定目標節點中執行時間存在衝突的節點之後，判斷每個執行時間存在衝突的節點所需的作業文件是否相同，若相同則基於每個執行時間存在衝突的節點所需的作用文件進行資源衝突校驗。這樣，只需對於存在執行時間衝突且執行任務所需的作業文件相同的節點進行資源衝突校驗，而對於不存在執行時間衝突的節點，以及即使存在執行時間衝突但執行任務所需的作業文件不同的節點，則無需進行資源衝突校驗，可以進一步地提高任務排程檢查的效率，從而提高任務執行的效率。
[0114]
在其中一個實施例中，執行時間存在衝突包括執行時間重合，基於每個執行時間存在衝突的節點所需的作用文件進行資源衝突校驗，包括：對於執行時間重合的節點所需的相同的作業文件，若同時存在寫操作，則確定存在資源衝突；對於執行時間重合的節點所需的相同的作業文件，若同時存在寫操作和讀操作，則確定存在資源衝突。
[0115]
其中，執行時間重合是一個目標節點的開始執行時間與另一目標節點的執行結束時間存在重合。
[0116]
具體地，伺服器根據預先配置的衝突規則和任務執行信息，對各任務流的目標節點的執行時間進行時間衝突校驗時，若發現一個目標節點的開始執行時間與另一目標節點的執行結束時間存在重合，則可以確定這兩個目標節點的執行時間重合，存在執行時間衝突。需要說明的是，兩個目標節點的執行時間重合只是用於解釋執行時間重合所用的泛指，實際上，也可能存在多個目標節點的執行時間重合。
[0117]
進而，伺服器對執行時間重合併且執行任務所需的作業文件相同的目標節點進行資源衝突校驗。若將執行時間重合的目標節點執行任務所需的相同的作業文件稱為目標作業文件，則伺服器所進行的資源衝突校驗，包括對執行時間重合的目標節點執行任務時對目標作業文件的操作情況進行校驗。每個目標節點在執行對應的任務時，可以對目標作業文件進行讀操作，也可以對目標作業文件進行寫操作。若存在同時對目標作業文件進行寫操作，則確定目標節點存在資源衝突；若一個目標節點在執行對應的任務時對目標作業文件進行寫操作，同時另一個目標節點在執行對應的任務時對目標作業文件進行讀操作，也確定相應的目標節點存在資源衝突。
[0118]
本實施例中，執行時間存在衝突包括執行時間重合，對於執行時間重合的節點所需的相同的作業文件，若同時存在寫操作，則確定存在資源衝突；對於執行時間重合的節點所需的相同的作業文件，若同時存在寫操作和讀操作，則確定存在資源衝突。這樣，可以檢查出存在執行時間重合的目標節點的資源衝突情況，進而提前發現多個任務流之間可能存在衝突，避免了可能由此引起的任務相互等待、任務中斷等情況，從而提高任務執行的效率。
[0119]
在其中一個實施例中，執行時間存在衝突包括執行時間間隔小於預設間隔，基於
每個執行時間存在衝突的節點所需的作用文件進行資源衝突校驗，包括：對於執行時間間隔小於預設間隔的節點所需的相同的作業文件，若同時存在寫操作，則確定存在資源衝突；對於執行時間間隔小於預設間隔的節點所需的相同的作業文件，若同時存在寫操作和讀操作，則確定存在資源衝突。
[0120]
其中，執行時間間隔指一個目標節點的開始執行時間，與另一目標節點的執行結束時間之間的時間間隔。
[0121]
具體地，伺服器根據預先配置的衝突規則和任務執行信息，對各任務流的目標節點的執行時間進行時間衝突校驗時，若發現一個目標節點的開始執行時間，與另一目標節點的執行結束時間之間的時間間隔小於預設間隔，則可以確定這兩個目標節點的執行時間間隔小於預設間隔，存在執行時間衝突。需要說明的是，兩個目標節點的執行時間間隔小於預設間隔只是用於解釋執行時間間隔小於預設間隔所用的泛指，實際上，也可能存在多個目標節點的執行時間間隔小於預設間隔。
[0122]
進而，伺服器對執行時間間隔小於預設間隔並且執行任務所需的作業文件相同的目標節點進行資源衝突校驗。若將執行時間間隔小於預設間隔的目標節點執行任務所需的相同的作業文件稱為目標作業文件，則伺服器所進行的資源衝突校驗，包括對執行時間間隔小於預設間隔的目標節點執行任務時對目標作業文件的操作情況進行校驗。若執行結束時間在前的目標節點執行任務時對目標作業文件進行寫操作，執行時間間隔小於預設間隔的後開始執行的目標節點，執行任務時對目標作業文件也進行寫操作，則確定目標節點存在資源衝突；若執行結束時間在前的目標節點執行任務時對目標作業文件進行寫操作，執行時間間隔小於預設間隔的後開始執行的目標節點，執行任務時對目標作業文件進行讀操作，也確定相應的目標節點存在資源衝突。
[0123]
本實施例中，執行時間存在衝突包括執行時間間隔小於預設間隔，對於執行時間間隔小於預設間隔的節點所需的相同的作業文件，若同時存在寫操作，則確定存在資源衝突；對於執行時間間隔小於預設間隔的節點所需的相同的作業文件，若同時存在寫操作和讀操作，則確定存在資源衝突。這樣，可以檢查出執行時間間隔小於預設間隔的目標節點的資源衝突情況，進而提前發現多個任務流之間可能存在衝突，避免了可能由此引起的任務相互等待、任務中斷等情況，從而提高任務執行的效率。
[0124]
下面參考圖7，再以一個具體的實施例來詳細說明本技術的任務排程檢查方法：
[0125]
工作人員通過終端制定作業流程，並根據作業流程填寫每個任務的任務定義信息。任務定義信息中一般包括任務名稱、任務的提交方式以及任務的前項。進而終端將制定完畢的作業流程發送至伺服器。
[0126]
伺服器接收到製作完畢的作業流程，確定作業流程中的多個任務以及每個任務的任務定義信息之後，根據每個任務的任務定義信息中的任務依賴關係生成任務圖，任務圖中包括多個任務流。
[0127]
生成的任務圖可以用鄰接矩陣表示，例如，對於包括4個任務的作業流程，其中，任務2和任務3依賴於任務1，任務4依賴於任務2和任務3，則伺服器會先構建一個4
×
4的初始矩陣，4行分別對應任務1、任務2、任務3和任務4，4列分別對應任務1、任務2、任務3和任務4。對於第1行第2列的元素，由於任務2依賴於任務1，則第1行第2列的元素可以確定為1。對初始矩陣中的每個元素，都根據所在行對應的任務、以及所在列對應的任務之間的任務依賴
關係確定對應的值，有依賴關係確定為1，沒有依賴關係確定為0，這樣就得到了這4個任務之間的鄰接矩陣。
[0128]
當任務數量較少時，生成的鄰接矩陣將存儲大量的0，浪費存儲空間，這時候可以選擇使用鄰接鍊表表示任務圖。使用鄰接鍊表可以更好地查詢連通性，其原理是用空間換時間。同樣以上述包括4個任務的作業流程為例，對於每個任務，伺服器生成對應的連結點，任務1對應連結點1、任務2對應連結點2、任務3對應連結點3、任務4對應連結點4，由於任務2和任務3依賴於任務1，則在連結點1後增加與連結點2和連結點3的連結關係，由於任務4依賴於任務2和任務3，則在連結點2和連結點3後增加與連結點4的連結關係，所有的連結點遍歷一次後，生成完整鄰接鍊表。
[0129]
任務圖生成之後，採用廣度優先或者深度優先的方式遍歷任務圖，並根據任務之間的依賴關係進行拓撲排序，得到任務執行鍊表，對任務執行鍊表進行有向無環圖的校驗。如果存在成環的情況，訪問的節點要做記錄，同時可用輔助隊列存放待訪問的鄰接節點。如果不成環，則為通過有向無環圖校驗的任務流的目標節點添加任務執行信息，任務執行信息包括執行任務所需的作業文件、以及任務執行時間。
[0130]
進而伺服器逐個目標節點按照配置的衝突規則進行遍歷校驗。配置的衝突規則有：
[0131]
規則1：開始執行時間與執行結束時間區間重合的目標節點，不能存在讀文件與寫文件重複；
[0132]
規則2：開始執行時間與執行結束時間區間重合的目標節點，不能存在寫文件與寫文件重複；
[0133]
規則3：開始執行時間與執行結束時間區間重合的目標節點，不能存在寫表與寫表重複；
[0134]
規則4：開始執行時間與執行結束時間區間間隔5分鐘內的目標節點，不能存在讀文件與寫文件重複；
[0135]
規則5：開始執行時間與執行結束時間區間間隔5分鐘內的目標節點，不能存在寫文件與寫文件重複；
[0136]
規則6：開始執行時間與執行結束時間區間間隔5分鐘內的目標節點，不能存在寫表與寫表重複。
[0137]
按照上述衝突規則，伺服器首先對各任務流的目標節點的執行時間進行時間衝突校驗，校驗各任務流的目標節點的開始執行時間與執行結束時間區間是否重合，或者開始執行時間與執行結束時間區間間隔是否在5分鐘內，若是，則校驗存在執行時間衝突的目標節點執行任務時是否需要相同的作業文件，作業文件可以是文件也可以是表，若是，則校驗存在執行時間衝突的目標節點執行任務時對所需的作業文件執行的是寫操作還是讀操作，若均是寫操作，則存在資源衝突，若一個目標節點為寫操作、另一目標節點為讀操作，也存在資源衝突。最後，伺服器根據上述衝突校驗結果得到任務排程檢查結果，任務排程檢查結果中包含存在衝突的作業名稱、以及衝突規則集合。
[0138]
上述任務排程檢查方法中，首先通過確定作業流程中的多個任務以及每個任務的任務定義信息，並根據每個任務的任務定義信息中的任務依賴關係生成任務圖，其次，基於任務圖對各個任務流分別進行有向無環圖校驗，若任務流通過有向無環圖校驗，則為通過
有向無環圖校驗的任務流的目標節點添加任務執行信息，任務執行信息包括執行任務所需的作業文件、以及任務執行時間，進而根據預先配置的衝突規則和任務執行信息，對各任務流的目標節點進行衝突校驗，最後根據衝突校驗結果得到任務排程檢查結果。這樣，當需要新增或修改任務時，通過有向無環圖校驗，以及校驗多個任務流在時間序列的衝突，能夠實現分布式任務準入檢查和衝突預防。如果多個任務流在生產上已經運行，通過修改衝突規則的預設間隔時間，可以提前發現隨著生產任務執行時間變化，多個任務流之間可能存在的衝突。從而能夠有效防止執行任務時爭搶資源，避免由此引起的任務相互等待、任務中斷等情況，提高任務執行的效率。
[0139]
應該理解的是，雖然如上所述的各實施例所涉及的流程圖中的各個步驟按照箭頭的指示依次顯示，但是這些步驟並不是必然按照箭頭指示的順序依次執行。除非本文中有明確的說明，這些步驟的執行並沒有嚴格的順序限制，這些步驟可以以其它的順序執行。而且，如上所述的各實施例所涉及的流程圖中的至少一部分步驟可以包括多個步驟或者多個階段，這些步驟或者階段並不必然是在同一時刻執行完成，而是可以在不同的時刻執行，這些步驟或者階段的執行順序也不必然是依次進行，而是可以與其它步驟或者其它步驟中的步驟或者階段的至少一部分輪流或者交替地執行。
[0140]
基於同樣的發明構思，在一個實施例中，如圖8所示，本技術實施例還提供了一種任務排程檢查裝置800，包括：確定模塊801、生成模塊802、第一校驗模塊803、添加模塊804以及第二校驗模塊805，其中：
[0141]
確定模塊，用於確定作業流程中的多個任務，並確定每個任務的任務定義信息；
[0142]
生成模塊，用於根據每個任務的任務定義信息中的任務依賴關係生成任務圖；任務圖中包括多個任務流；
[0143]
第一校驗模塊，用於基於任務圖對各個任務流分別進行有向無環圖校驗；
[0144]
添加模塊，用於為通過有向無環圖校驗的任務流的目標節點添加任務執行信息；任務執行信息包括執行任務所需的作業文件、以及任務執行時間；
[0145]
第二校驗模塊，用於根據預先配置的衝突規則和任務執行信息，對各任務流的目標節點進行衝突校驗，並根據衝突校驗結果得到任務排程檢查結果。
[0146]
在其中一個實施例中，任務圖包括鄰接矩陣，生成模塊還用於基於多個任務的數量構建初始矩陣，初始矩陣的每一行對應一個任務，初始矩陣的每一列對應一個任務；對於初始矩陣中的當前元素，根據當前元素所在行對應的任務、以及當前元素所在列對應的任務之間的任務依賴關係，確定當前元素的值；當前元素為初始矩陣中的任一個元素；根據各個元素的值，得到鄰接矩陣。
[0147]
在其中一個實施例中，任務圖包括鄰接鍊表，生成模塊還用於生成與各個任務分別對應的連結點；遍歷各連結點，並根據任務定義信息中的任務依賴關係，對具有依賴關係的任務所對應的連結點之間增加連結關係，得到鄰接鍊表。
[0148]
在其中一個實施例中，第一校驗模塊還用於遍歷任務圖中的各節點並進行拓撲排序，得到與各個任務流對應的任務執行鍊表；對任務執行鍊表進行是否成環校驗，若不成環則確定相應的任務流通過有向無環圖校驗。
[0149]
在其中一個實施例中，第二校驗模塊還用於根據預先配置的衝突規則和任務執行信息，對各任務流的目標節點的執行時間進行時間衝突校驗；確定目標節點中執行時間存
在衝突的節點，並判斷每個執行時間存在衝突的節點所需的作業文件是否相同，若相同則基於每個執行時間存在衝突的節點所需的作用文件進行資源衝突校驗。
[0150]
在其中一個實施例中，執行時間存在衝突包括執行時間重合，第二校驗模塊還用於對於執行時間重合的節點所需的相同的作業文件，若同時存在寫操作，則確定存在資源衝突；對於執行時間重合的節點所需的相同的作業文件，若同時存在寫操作和讀操作，則確定存在資源衝突。
[0151]
在其中一個實施例中，執行時間存在衝突包括執行時間間隔小於預設間隔，第二校驗模塊還用於對於執行時間間隔小於預設間隔的節點所需的相同的作業文件，若同時存在寫操作，則確定存在資源衝突；對於執行時間間隔小於預設間隔的節點所需的相同的作業文件，若同時存在寫操作和讀操作，則確定存在資源衝突。
[0152]
上述任務排程檢查裝置中的各個模塊可全部或部分通過軟體、硬體及其組合來實現。上述各模塊可以硬體形式內嵌於或獨立於計算機設備中的處理器中，也可以以軟體形式存儲於計算機設備中的存儲器中，以便於處理器調用執行以上各個模塊對應的操作。
[0153]
在一個實施例中，提供了一種計算機設備，該計算機設備可以是終端，其內部結構圖可以如圖9所示。該計算機設備包括處理器、存儲器、輸入/輸出接口、通信接口、顯示單元和輸入裝置。其中，處理器、存儲器和輸入/輸出接口通過系統總線連接，通信接口、顯示單元和輸入裝置通過輸入/輸出接口連接到系統總線。其中，該計算機設備的處理器用於提供計算和控制能力。該計算機設備的存儲器包括非易失性存儲介質和內存儲器。該非易失性存儲介質存儲有作業系統和電腦程式。該內存儲器為非易失性存儲介質中的作業系統和電腦程式的運行提供環境。該計算機設備的輸入/輸出接口用於處理器與外部設備之間交換信息。該計算機設備的通信接口用於與外部的終端進行有線或無線方式的通信，無線方式可通過wifi、移動蜂窩網絡、nfc(近場通信)或其他技術實現。該電腦程式被處理器執行時以實現一種任務排程檢查方法。該計算機設備的顯示單元用於形成視覺可見的畫面，可以是顯示屏、投影裝置或虛擬實境成像裝置。顯示屏可以是液晶顯示屏或者電子墨水顯示屏，該計算機設備的輸入裝置可以是顯示屏上覆蓋的觸摸層，也可以是計算機設備外殼上設置的按鍵、軌跡球或觸控板，還可以是外接的鍵盤、觸控板或滑鼠等。
[0154]
本領域技術人員可以理解，圖9中示出的結構，僅僅是與本技術方案相關的部分結構的框圖，並不構成對本技術方案所應用於其上的計算機設備的限定，具體的計算機設備可以包括比圖中所示更多或更少的部件，或者組合某些部件，或者具有不同的部件布置。
[0155]
在一個實施例中，提供了一種計算機設備，包括存儲器和處理器，存儲器中存儲有電腦程式，該處理器執行電腦程式時實現以下步驟：
[0156]
確定作業流程中的多個任務，並確定每個任務的任務定義信息；
[0157]
根據每個任務的任務定義信息中的任務依賴關係生成任務圖；任務圖中包括多個任務流；
[0158]
基於任務圖對各個任務流分別進行有向無環圖校驗；
[0159]
為通過有向無環圖校驗的任務流的目標節點添加任務執行信息；任務執行信息包括執行任務所需的作業文件、以及任務執行時間；
[0160]
根據預先配置的衝突規則和任務執行信息，對各任務流的目標節點進行衝突校驗，並根據衝突校驗結果得到任務排程檢查結果。
[0161]
在一個實施例中，任務圖包括鄰接矩陣，處理器執行電腦程式時還實現以下步驟：基於多個任務的數量構建初始矩陣，初始矩陣的每一行對應一個任務，初始矩陣的每一列對應一個任務；對於初始矩陣中的當前元素，根據當前元素所在行對應的任務、以及當前元素所在列對應的任務之間的任務依賴關係，確定當前元素的值；當前元素為初始矩陣中的任一個元素；根據各個元素的值，得到鄰接矩陣。
[0162]
在一個實施例中，任務圖包括鄰接鍊表，處理器執行電腦程式時還實現以下步驟：生成與各個任務分別對應的連結點；遍歷各連結點，並根據任務定義信息中的任務依賴關係，對具有依賴關係的任務所對應的連結點之間增加連結關係，得到鄰接鍊表。
[0163]
在一個實施例中，處理器執行電腦程式時還實現以下步驟：遍歷任務圖中的各節點並進行拓撲排序，得到與各個任務流對應的任務執行鍊表；對任務執行鍊表進行是否成環校驗，若不成環則確定相應的任務流通過有向無環圖校驗。
[0164]
在一個實施例中，處理器執行電腦程式時還實現以下步驟：根據預先配置的衝突規則和任務執行信息，對各任務流的目標節點的執行時間進行時間衝突校驗；確定目標節點中執行時間存在衝突的節點，並判斷每個執行時間存在衝突的節點所需的作業文件是否相同，若相同則基於每個執行時間存在衝突的節點所需的作用文件進行資源衝突校驗。
[0165]
在一個實施例中，執行時間存在衝突包括執行時間重合，處理器執行電腦程式時還實現以下步驟：對於執行時間重合的節點所需的相同的作業文件，若同時存在寫操作，則確定存在資源衝突；對於執行時間重合的節點所需的相同的作業文件，若同時存在寫操作和讀操作，則確定存在資源衝突。
[0166]
在一個實施例中，執行時間存在衝突包括執行時間間隔小於預設間隔，處理器執行電腦程式時還實現以下步驟：對於執行時間間隔小於預設間隔的節點所需的相同的作業文件，若同時存在寫操作，則確定存在資源衝突；對於執行時間間隔小於預設間隔的節點所需的相同的作業文件，若同時存在寫操作和讀操作，則確定存在資源衝突。
[0167]
在一個實施例中，提供了一種計算機可讀存儲介質，其上存儲有電腦程式，電腦程式被處理器執行時實現以下步驟：
[0168]
確定作業流程中的多個任務，並確定每個任務的任務定義信息；
[0169]
根據每個任務的任務定義信息中的任務依賴關係生成任務圖；任務圖中包括多個任務流；
[0170]
基於任務圖對各個任務流分別進行有向無環圖校驗；
[0171]
為通過有向無環圖校驗的任務流的目標節點添加任務執行信息；任務執行信息包括執行任務所需的作業文件、以及任務執行時間；
[0172]
根據預先配置的衝突規則和任務執行信息，對各任務流的目標節點進行衝突校驗，並根據衝突校驗結果得到任務排程檢查結果。
[0173]
在一個實施例中，任務圖包括鄰接矩陣，電腦程式被處理器執行時還實現以下步驟：基於多個任務的數量構建初始矩陣，初始矩陣的每一行對應一個任務，初始矩陣的每一列對應一個任務；對於初始矩陣中的當前元素，根據當前元素所在行對應的任務、以及當前元素所在列對應的任務之間的任務依賴關係，確定當前元素的值；當前元素為初始矩陣中的任一個元素；根據各個元素的值，得到鄰接矩陣。
[0174]
在一個實施例中，任務圖包括鄰接鍊表，電腦程式被處理器執行時還實現以下
步驟：生成與各個任務分別對應的連結點；遍歷各連結點，並根據任務定義信息中的任務依賴關係，對具有依賴關係的任務所對應的連結點之間增加連結關係，得到鄰接鍊表。
[0175]
在一個實施例中，電腦程式被處理器執行時還實現以下步驟：遍歷任務圖中的各節點並進行拓撲排序，得到與各個任務流對應的任務執行鍊表；對任務執行鍊表進行是否成環校驗，若不成環則確定相應的任務流通過有向無環圖校驗。
[0176]
在一個實施例中，電腦程式被處理器執行時還實現以下步驟：根據預先配置的衝突規則和任務執行信息，對各任務流的目標節點的執行時間進行時間衝突校驗；確定目標節點中執行時間存在衝突的節點，並判斷每個執行時間存在衝突的節點所需的作業文件是否相同，若相同則基於每個執行時間存在衝突的節點所需的作用文件進行資源衝突校驗。
[0177]
在一個實施例中，執行時間存在衝突包括執行時間重合，電腦程式被處理器執行時還實現以下步驟：對於執行時間重合的節點所需的相同的作業文件，若同時存在寫操作，則確定存在資源衝突；對於執行時間重合的節點所需的相同的作業文件，若同時存在寫操作和讀操作，則確定存在資源衝突。
[0178]
在一個實施例中，執行時間存在衝突包括執行時間間隔小於預設間隔，電腦程式被處理器執行時還實現以下步驟：對於執行時間間隔小於預設間隔的節點所需的相同的作業文件，若同時存在寫操作，則確定存在資源衝突；對於執行時間間隔小於預設間隔的節點所需的相同的作業文件，若同時存在寫操作和讀操作，則確定存在資源衝突。
[0179]
在一個實施例中，提供了一種電腦程式產品，包括電腦程式，該電腦程式被處理器執行時實現上述各方法實施例中的步驟。
[0180]
本領域普通技術人員可以理解實現上述實施例方法中的全部或部分流程，是可以通過電腦程式來指令相關的硬體來完成，所述的電腦程式可存儲於一非易失性計算機可讀取存儲介質中，該電腦程式在執行時，可包括如上述各方法的實施例的流程。其中，本技術所提供的各實施例中所使用的對存儲器、資料庫或其它介質的任何引用，均可包括非易失性和易失性存儲器中的至少一種。非易失性存儲器可包括只讀存儲器(read-only memory，rom)、磁帶、軟盤、快閃記憶體、光存儲器、高密度嵌入式非易失性存儲器、阻變存儲器(reram)、磁變存儲器(magnetoresistive random access memory，mram)、鐵電存儲器(ferroelectric random access memory，fram)、相變存儲器(phase change memory，pcm)、石墨烯存儲器等。易失性存儲器可包括隨機存取存儲器(random access memory，ram)或外部高速緩衝存儲器等。作為說明而非局限，ram可以是多種形式，比如靜態隨機存取存儲器(static random access memory，sram)或動態隨機存取存儲器(dynamic random access memory，dram)等。本技術所提供的各實施例中所涉及的資料庫可包括關係型資料庫和非關係型資料庫中至少一種。非關係型資料庫可包括基於區塊鏈的分布式資料庫等，不限於此。本技術所提供的各實施例中所涉及的處理器可為通用處理器、中央處理器、圖形處理器、數位訊號處理器、可編程邏輯器、基於量子計算的數據處理邏輯器等，不限於此。
[0181]
以上實施例的各技術特徵可以進行任意的組合，為使描述簡潔，未對上述實施例中的各個技術特徵所有可能的組合都進行描述，然而，只要這些技術特徵的組合不存在矛盾，都應當認為是本說明書記載的範圍。
[0182]
以上所述實施例僅表達了本技術的幾種實施方式，其描述較為具體和詳細，但並
不能因此而理解為對本技術專利範圍的限制。應當指出的是，對於本領域的普通技術人員來說，在不脫離本技術構思的前提下，還可以做出若干變形和改進，這些都屬於本技術的保護範圍。因此，本技術的保護範圍應以所附權利要求為準。