[發(fā)明專利]定時(shí)任務(wù)處理方法及裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201810084155.6
• 申請(qǐng)日: 2018-01-29
• 公開（公告）號(hào): CN110096340B
• 公開（公告）日: 2020-11-17
• 發(fā)明（設(shè)計(jì)）人: 宋西軍
• 申請(qǐng)（專利權(quán)）人: 北京世紀(jì)好未來教育科技有限公司
• 主分類號(hào): G06F9/46
• 分類號(hào): G06F9/46;G06F9/54;G06F11/14
• 代理公司: 北京合智同創(chuàng)知識(shí)產(chǎn)權(quán)代理有限公司 11545
• 代理人: 李杰

1.一種定時(shí)任務(wù)處理方法，其特征在于，包括：

通過定時(shí)任務(wù)的隊(duì)列維護(hù)線程對(duì)應(yīng)的I/O多路復(fù)用模型進(jìn)行定時(shí)任務(wù)監(jiān)聽；

在監(jiān)聽到新的定時(shí)任務(wù)后，通過所述I/O多路復(fù)用模型激活所述隊(duì)列維護(hù)線程；

讀取所述定時(shí)任務(wù)的數(shù)據(jù)，并寫入激活的所述隊(duì)列維護(hù)線程，其中，所述定時(shí)任務(wù)的數(shù)據(jù)包括：所述定時(shí)任務(wù)的任務(wù)數(shù)據(jù)、所述定時(shí)任務(wù)的定時(shí)時(shí)間；

根據(jù)所述定時(shí)任務(wù)的定時(shí)時(shí)間，將所述定時(shí)任務(wù)加入所述隊(duì)列維護(hù)線程維護(hù)的定時(shí)任務(wù)隊(duì)列，其中，所述定時(shí)任務(wù)隊(duì)列中的定時(shí)任務(wù)按照定時(shí)時(shí)間從小到大排列；

在所述定時(shí)任務(wù)隊(duì)列中的每個(gè)定時(shí)任務(wù)的定時(shí)時(shí)間，觸發(fā)任務(wù)分發(fā)線程分發(fā)對(duì)應(yīng)的定時(shí)任務(wù)。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述方法還包括：

通過所述I/O多路復(fù)用模型監(jiān)聽所述隊(duì)列維護(hù)線程的定時(shí)任務(wù)隊(duì)列；

根據(jù)監(jiān)聽結(jié)果，確定所述定時(shí)任務(wù)隊(duì)列中的至少一個(gè)隊(duì)列任務(wù)到達(dá)其定時(shí)時(shí)間時(shí)，激活所述隊(duì)列維護(hù)線程將所述至少一個(gè)隊(duì)列任務(wù)寫入所述任務(wù)分發(fā)線程進(jìn)行定時(shí)任務(wù)分發(fā)。

3.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，所述定時(shí)任務(wù)隊(duì)列根據(jù)所述定時(shí)任務(wù)的定時(shí)時(shí)間，通過最小堆算法生成。

4.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，

所述通過定時(shí)任務(wù)的隊(duì)列維護(hù)線程對(duì)應(yīng)的I/O多路復(fù)用模型進(jìn)行定時(shí)任務(wù)監(jiān)聽，包括：通過定時(shí)任務(wù)的隊(duì)列維護(hù)線程對(duì)應(yīng)的I/O多路復(fù)用模型對(duì)請(qǐng)求分發(fā)線程進(jìn)行定時(shí)任務(wù)監(jiān)聽；

所述監(jiān)聽到新的定時(shí)任務(wù)，包括：監(jiān)聽到所述請(qǐng)求分發(fā)線程發(fā)出定時(shí)任務(wù)到達(dá)指令；

所述讀取所述定時(shí)任務(wù)的數(shù)據(jù)，包括：從所述請(qǐng)求分發(fā)線程讀取所述定時(shí)任務(wù)的數(shù)據(jù)。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，在所述通過定時(shí)任務(wù)的隊(duì)列維護(hù)線程對(duì)應(yīng)的I/O多路復(fù)用模型進(jìn)行定時(shí)任務(wù)監(jiān)聽之前，所述方法還包括：

通過主線程對(duì)所述請(qǐng)求分發(fā)線程、所述隊(duì)列維護(hù)線程和所述任務(wù)分發(fā)線程進(jìn)行初始化并分別建立對(duì)應(yīng)的套接字對(duì)；

其中，所述套接字對(duì)用于線程之間的I/O通信；所述請(qǐng)求分發(fā)線程、所述隊(duì)列維護(hù)線程和所述任務(wù)分發(fā)線程由所述主線程創(chuàng)建。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，

在所述通過主線程對(duì)所述請(qǐng)求分發(fā)線程、所述隊(duì)列維護(hù)線程和所述任務(wù)分發(fā)線程進(jìn)行初始化并分別生成對(duì)應(yīng)的套接字對(duì)之前，所述方法還包括：?jiǎn)?dòng)所述主線程并為所述主線程建立第一套接字和主線程套接字對(duì)，將所述主線程的第一套接字與設(shè)定的監(jiān)聽地址綁定；

在所述通過主線程對(duì)所述請(qǐng)求分發(fā)線程、所述隊(duì)列維護(hù)線程和所述任務(wù)分發(fā)線程進(jìn)行初始化并分別生成對(duì)應(yīng)的套接字對(duì)之后，所述方法還包括：通過所述主線程的第一套接字對(duì)所述監(jiān)聽地址進(jìn)行定時(shí)任務(wù)監(jiān)聽，并在監(jiān)聽到有定時(shí)任務(wù)到達(dá)時(shí)，通過建立的所述主線程套接字對(duì)將所述第一套接字傳遞給所述請(qǐng)求分發(fā)線程，由所述請(qǐng)求分發(fā)線程從所述第一套接字接收所述定時(shí)任務(wù)。

7.根據(jù)權(quán)利要求6所述的方法，其特征在于，所述方法還包括：

通過所述請(qǐng)求分發(fā)線程對(duì)接收的所述定時(shí)任務(wù)進(jìn)行格式校驗(yàn)，其中，所述格式校驗(yàn)用于校驗(yàn)以下數(shù)據(jù)：所述定時(shí)任務(wù)的執(zhí)行對(duì)象的地址數(shù)據(jù)、所述定時(shí)任務(wù)的定時(shí)時(shí)間、所述定時(shí)任務(wù)的失敗重試次數(shù)、所述定時(shí)任務(wù)的失敗重試間隔、所述定時(shí)任務(wù)的任務(wù)數(shù)據(jù)；

在所述格式校驗(yàn)通過后，將所述定時(shí)任務(wù)存儲(chǔ)至本地磁盤，并將所述定時(shí)任務(wù)發(fā)送給所述隊(duì)列維護(hù)線程。

8.根據(jù)權(quán)利要求7所述的方法，其特征在于，所述方法還包括：

通過所述請(qǐng)求分發(fā)線程接收定時(shí)任務(wù)同步請(qǐng)求，根據(jù)所述同步請(qǐng)求將本地磁盤中保存的定時(shí)任務(wù)的數(shù)據(jù)同步至備份設(shè)備。