[發(fā)明專利]數(shù)據(jù)延遲處理方法和裝置、計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)

有效

• 申請(qǐng)?zhí)枺?/td>: 201710510902.3
• 申請(qǐng)日: 2017-06-29
• 公開(kāi)（公告）號(hào): CN107329807B
• 公開(kāi)（公告）日: 2020-06-30
• 發(fā)明（設(shè)計(jì)）人: 徐開(kāi)廷
• 申請(qǐng)（專利權(quán)）人: 北京京東尚科信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司
• 主分類號(hào): G06F9/46
• 分類號(hào): G06F9/46;G06F11/07
• 代理公司: 中國(guó)國(guó)際貿(mào)易促進(jìn)委員會(huì)專利商標(biāo)事務(wù)所 11038
• 代理人: 王莉莉

本發(fā)明公開(kāi)了一種數(shù)據(jù)延遲處理方法和裝置，涉及數(shù)據(jù)處理技術(shù)領(lǐng)域。該方法包括：i)建立包含N₁個(gè)結(jié)點(diǎn)的循環(huán)鏈表，N₁根據(jù)任務(wù)處理間隔T_s和任務(wù)延遲時(shí)長(zhǎng)T_d來(lái)確定，N₁為大于1的整數(shù)；ii)為循環(huán)鏈表設(shè)置讀指針和寫指針，寫指針指向的結(jié)點(diǎn)為讀指針指向的結(jié)點(diǎn)的上一個(gè)結(jié)點(diǎn)；iii)將接收到的任務(wù)寫入寫指針指向的結(jié)點(diǎn)中，讀取讀指針指向的結(jié)點(diǎn)中的任務(wù)并執(zhí)行；iv)將寫指針和讀指針均移動(dòng)到下一個(gè)結(jié)點(diǎn)；v)重復(fù)步驟iii)和iv)，直到處理完所有任務(wù)。該方法和裝置能夠提高數(shù)據(jù)處理的效率。

技術(shù)領(lǐng)域

本發(fā)明涉及數(shù)據(jù)處理技術(shù)領(lǐng)域，特別涉及一種數(shù)據(jù)延遲處理方法和裝置、計(jì)算機(jī)可讀存儲(chǔ)介質(zhì)。

背景技術(shù)

在數(shù)據(jù)處理領(lǐng)域，常常遇到需要對(duì)任務(wù)進(jìn)行延遲處理的情況。例如，在電子商務(wù)中，接收到用戶的訂單后需要等待若干分鐘，若這段時(shí)間內(nèi)同一個(gè)用戶下達(dá)了其它訂單，則可以把這些訂單進(jìn)行合并派送，從而減少資源的浪費(fèi)。

在現(xiàn)有技術(shù)的技術(shù)方案中，需要記錄每個(gè)任務(wù)的發(fā)起時(shí)間和狀態(tài)信息，同時(shí)設(shè)置定時(shí)器，每隔固定的時(shí)長(zhǎng)就將任務(wù)的發(fā)起時(shí)間和當(dāng)前時(shí)間進(jìn)行比較，并執(zhí)行符合延遲時(shí)長(zhǎng)的任務(wù)。

發(fā)明內(nèi)容

本發(fā)明的發(fā)明人發(fā)現(xiàn)上述現(xiàn)有技術(shù)中存在如下問(wèn)題：每次執(zhí)行任務(wù)的時(shí)候，都需要將所有任務(wù)的發(fā)起時(shí)間與當(dāng)前時(shí)間進(jìn)行比較，導(dǎo)致數(shù)據(jù)處理效率低下。針對(duì)上述問(wèn)題中的至少一個(gè)問(wèn)題，本發(fā)明人提出了解決方案。

本發(fā)明的一個(gè)目的是提供一種數(shù)據(jù)延遲處理技術(shù)方案。

根據(jù)本發(fā)明的一個(gè)實(shí)施例，提供了一種數(shù)據(jù)延遲處理方法，包括：i)建立包含N₁個(gè)結(jié)點(diǎn)的循環(huán)鏈表，N₁根據(jù)任務(wù)處理間隔T_s和任務(wù)延遲時(shí)長(zhǎng)T_d來(lái)確定，N₁為大于1的整數(shù)；ii)為所述循環(huán)鏈表設(shè)置讀指針和寫指針，所述寫指針指向的結(jié)點(diǎn)為所述讀指針指向的結(jié)點(diǎn)的上一個(gè)結(jié)點(diǎn)；iii)將接收到的任務(wù)寫入所述寫指針指向的結(jié)點(diǎn)中，讀取所述讀指針指向的結(jié)點(diǎn)中的任務(wù)并執(zhí)行；iv)將所述寫指針和所述讀指針均移動(dòng)到下一個(gè)結(jié)點(diǎn)；v)重復(fù)步驟iii)和iv)，直到處理完所有任務(wù)。

可選地，

可選地，根據(jù)任務(wù)發(fā)起者為接收到的所述任務(wù)設(shè)置標(biāo)識(shí)位；記錄所述任務(wù)、所述標(biāo)識(shí)位和所述任務(wù)所在結(jié)點(diǎn)位置的對(duì)應(yīng)關(guān)系；判斷是否存在與所述讀指針指向的結(jié)點(diǎn)中的任務(wù)具有相同標(biāo)識(shí)位的任務(wù)，如果有，則將具有相同標(biāo)識(shí)位的任務(wù)合并執(zhí)行。

可選地，在需要將T_d延長(zhǎng)ΔT₁的情況下，在所述寫指針指向的結(jié)點(diǎn)與下一個(gè)結(jié)點(diǎn)之間插入N₂個(gè)結(jié)點(diǎn)，N₂根據(jù)T_s和ΔT₁確定，N₂為正整數(shù)；將所述寫指針向所述下一個(gè)結(jié)點(diǎn)方向移動(dòng)，依次指向所述插入的結(jié)點(diǎn)，同時(shí)按照接收順序?qū)⑷蝿?wù)分別寫入所述寫指針指向的結(jié)點(diǎn)，將所述讀指針停留在當(dāng)前指向的結(jié)點(diǎn)處直到ΔT₁結(jié)束。

可選地，

可選地，在需要將T_d縮短ΔT₂的情況下，將所述讀指針向下一個(gè)結(jié)點(diǎn)方向移動(dòng)，讀取所述讀指針依次指向的N₃個(gè)結(jié)點(diǎn)中的任務(wù)并執(zhí)行后，刪除N₃個(gè)所述結(jié)點(diǎn)，N₃根據(jù)T_s和ΔT₂確定；將所述寫指針停留在當(dāng)前指向的結(jié)點(diǎn)處直到刪除操作結(jié)束。

可選地，