[發明專利]基于緩存數據多線程處理的電力可靠性指標快速計算方法

有效

• 申請號: 201310373229.5
• 申請日: 2013-08-23
• 公開（公告）號: CN103488684A
• 公開（公告）日: 2014-01-01
• 發明（設計）人: 吳猛;黃燦;俞俊;羅黎明;施康;李林輝
• 申請（專利權）人: 國家電網公司;國網電力科學研究院;南京南瑞集團公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 南京縱橫知識產權代理有限公司 32224
• 代理人: 董建林

1.一種基于緩存數據多線程處理的電力可靠性指標快速計算方法，其特征在于，該方法包括以下步驟：

（1）在內存中創建數據緩存區，按業務數據類型劃分，以管理單位、設備注冊年月或停電發生年月為主鍵建立數據塊，緩存基礎數據；

（2)在每個數據塊中建立變更緩沖區，記錄發生變更的數據，并定時將變更緩沖區數據與數據塊中基礎數據合并，清空變更緩沖區；

（3)根據用戶提交的可靠性指標計算請求所輸入的條件，在數據緩存區中檢索參與計算的數據塊；

（4)?根據系統當前設定的最大線程數，將檢索出參與計算的數據塊中數據平均切割成多組，并創建多個基礎指標計算線程和一個基礎指標合并線程；

（5)所有基礎指標計算線程完成基礎指標計算后，由基礎指標合并線程將各基礎指標計算線程計算出的基礎指標結果進行合并，計算各級管理單位可靠性綜合指標。

2.根據權利要求1所述的基于緩存數據多線程處理的電力可靠性指標快速計算方法，其特征在于，上述步驟（1）在內存中創建數據緩存區，緩存基礎數據包括以下步驟：

（1a）按業務數據類型劃分，在數據緩存區中創建業務內存對象，并初始化；初始化的信息包括指定對象數據來源、所需要讀取的字段、設定數據塊內數據排序字段、抽取數據所用的過濾條件;

（1b）從外部數據源讀取基礎數據，同時按管理單位、注冊日期或停電時間進行排序，在內存中形成原始數據記錄集；

（1c）遍歷步驟(1b)中形成的原始數據記錄集中的數據，根據管理單位、設備注冊年月或停電發生年月新建數據塊，或將數據寫入已有的數據塊；

（1d）建立由管理單位、設備注冊年月或停電發生年月形成的主鍵與數據塊地址指針的數據塊列表。

3.根據權利要求1所述的基于緩存數據多線程處理的電力可靠性指標快速計算方法，其特征在于，上述步驟（1）中，所述的數據塊中基礎數據區內部數據排序方式為：設備注冊數據按設備注冊日期排序，設備運行數據按停電開始時間排序。

4.根據權利要求1所述的基于緩存數據多線程處理的電力可靠性指標快速計算方法，其特征在于，上述步驟（2）在每個數據塊中建立數據變更緩沖區，清空緩沖區包括以下步驟：

（2a）在每個數據塊中建立數據變更緩沖區，在變更緩沖區中創建三個列表分別為新增列表、修改列表和刪除列表；

（2b）定時根據外部數據源提供的基礎數據變更信息，將發生變更的基礎數據按變更類型分別讀取至新增列表、修改列表和刪除列表；

（2c）定時將新增列表、修改列表和刪除列表中的數據與數據塊中基礎數據進行合并；

（2d）清空新增列表、修改列表和刪除列表。

5.根據權利要求1所述的基于緩存數據多線程處理的電力可靠性指標快速計算方法，其特征在于，上述步驟（3）中，包括如下步驟：

（3a）從數據庫中獲取用戶提交的可靠性指標計算請求，并將其轉換成篩選基礎數據條件的內存對象；

（3b）遍歷所有業務內存對象的數據塊，依據數據塊主鍵信息和指標計算所涉及的起始時間篩選數據塊；

（3c）將篩選出的參與計算的數據塊通過地址指針的方式添加至計算數據塊列表中。

6.根據權利要求1所述的基于緩存數據多線程處理的電力可靠性指標快速計算方法，其特征在于，上述步驟（4）中，包括以下步驟：

（4a）根據系統當前設定的最大線程數和計算數據塊列表中參與計算的基礎數據總記錄數確定數據組的數目，以及切割后每個數據組所含基礎數據的平均數量；

（4b）遍歷計算數據塊列表中所有數據塊，遍歷數據塊的同時創建基礎數據容量為步驟(4a)中所述平均數量的數據組，如果當前數據塊中所包含的基礎數據量大于當前數據組剩余容量時，則拆分數據塊中的基礎數據先將當前數據組填充滿，再將剩余的基礎數據添加至新的數據組中；如果當前數據塊中所包含的基礎數據量小于當前數據組剩余容量時則不進行拆分，直接將其添加至當前數據組中；

（4c）根據數據組的數量，創建多個基礎指標計算線程，并形成基礎指標計算任務列表；將每組數據提交至所創建的基礎指標計算線程，且將線程對應的基礎指標計算任務狀態設置為計算中；

（4d）創建一個基礎指標合并線程。

7.根據權利要求1所述的基于緩存數據多線程處理的電力可靠性指標快速計算方法，其特征在于，上述步驟（5）中，包括以下步驟：

（5a）每個基礎指標計算線程遍歷所處理的數據組中每一條基礎數據，以及相應數據塊中的變更緩沖區新增列表中的數據，并根據篩選基礎數據條件的內存對象判斷該條基礎數據是否參與計算，如果參與計算則將該條數據提交基礎指標計算單元進行計算，計算結果存入基礎指標結果列表中，如果不參與則處理下一條基礎數據，直至該組數據全部處理完成；

（5b）每個基礎指標計算線程完成后，將該線程對應的計算任務狀態設置為完成；

（5c）遍歷基礎指標計算任務列表中的任務，判斷所有任務是否都已經執行完成，如果沒有全部完成則休眠1秒鐘再后執行步驟（5b），如果全部完成則執行步驟（5d）；

（5d）遍歷基礎指標結果列表中的每一條結果記錄，將同一單位的結果記錄中的基礎指標進行合并，計算該管理單位的可靠性綜合指標，并將全部指標結果寫入可靠性指標結果列表中；

（5e）將可靠性指標結果列表中的指標結果寫入數據庫，反饋給用戶。