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