本文介紹了基于時(shí)間的線程安全優(yōu)先級(jí)隊(duì)列的處理方法，對(duì)大家解決問(wèn)題具有一定的參考價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)吧！
問(wèn)題描述
我需要一些類似隊(duì)列的數(shù)據(jù)結(jié)構(gòu)來(lái)執(zhí)行以下任務(wù)：
-
有些線程添加了附加延遲值的數(shù)據(jù)項(xiàng)(例如秒)，例如
queue.add(data, delay)。既可以有不同的延遲，也可以有相同的延遲，隊(duì)列應(yīng)充當(dāng)優(yōu)先隊(duì)列：延遲越小的項(xiàng)越接近末尾(出隊(duì)速度更快)
排隊(duì)項(xiàng)每秒鐘
delay應(yīng)減1，直到達(dá)到0(然后保持不變?yōu)?)在
delay為0的項(xiàng)目中，出列順序就是它們的插入順序(雖然到達(dá)0的順序更好)一些客戶端線程系統(tǒng)地從該隊(duì)列中獲取元素，并且它只提供
delay = 0元素。如果不存在，則它將阻塞或引發(fā)。
因此，我想要一些隊(duì)列的功能+一點(diǎn)調(diào)度、線程安全。我懷疑，在某些情況下，這類事情應(yīng)該是一項(xiàng)相當(dāng)常規(guī)的任務(wù)。
我的問(wèn)題：對(duì)于此類任務(wù)，是否有針對(duì)java或scala的生產(chǎn)就緒解決方案？我不想再發(fā)明另一輛自行車了。
編輯：似乎在Java標(biāo)準(zhǔn)庫(kù)中確實(shí)有這樣的東西：DelayQueue，在回答之前先看一看。
推薦答案
您可以使用應(yīng)作為輸入Comparable對(duì)象的PriorityQueue。
您應(yīng)該基于Timestamp字段比較這些對(duì)象(越小越好)；正如@Henry已經(jīng)提到的，存儲(chǔ)Timestamp比存儲(chǔ)delay更好。這非常容易實(shí)現(xiàn)；只需存儲(chǔ)currentTime + delay。
然后，當(dāng)客戶端請(qǐng)求head元素時(shí)，您需要?jiǎng)?chuàng)建一個(gè)synchronized方法，該方法執(zhí)行以下操作：
首先peek()檢查head元素是否有timestamp < currentTime
如果是，poll()這個(gè)元素，否則拋出。
第二個(gè)解決方案(移植自我的評(píng)論)：
實(shí)際上，可以添加一個(gè)ScheduledThreadPoolExecutor作為中間層；
現(xiàn)在您不需要Timestamp，只需將delay提供給Executor。
當(dāng)每個(gè)runnable/callable執(zhí)行時(shí)，相應(yīng)的對(duì)象被添加到另一個(gè)正常的FIFO隊(duì)列，在那里它將立即可用于輪詢；
您的客戶端現(xiàn)在可以輪詢第二個(gè)FIFO隊(duì)列中的元素。
這篇關(guān)于基于時(shí)間的線程安全優(yōu)先級(jí)隊(duì)列的文章就介紹到這了，希望我們推薦的答案對(duì)大家有所幫助，
