需要混合使用Delayed和Map

Question

我有一個沒有保存按鈕的應用程序;後臺自動保存。當用戶使用應用程序時，創建任務並放入隊列中執行。其中一些延遲，例如，當你開始輸入時，我會等待200毫秒，然後再更新數據庫中的相應值。

爲了使這個更簡單的使用代碼明智的，我想能夠添加一個任務延遲和一個「關鍵」的隊列。如果已經有一個具有相同「密鑰」的任務，那麼我的第二個任務應該被忽略（因爲同一個操作已經排隊）。

這樣的事情已經存在嗎？

Answer 1

我想你應該看看TreeMap類。使用可以傳遞比較器的構造函數。這樣你可以讓Map排序爲Delayed（因爲這個類實現了Comparable接口）。在向地圖添加「任務」之前，請使用containsKey方法檢查密鑰是否已存在。

Answer 2

這是我的理解問題，並會接受挑戰：

任務包裝紙包裹任務或命令，並增加了額外的價值，爲任務和標識的延遲。我明白，兩項任務可能具有相同的「關鍵」，所以我們不能只執行任務哈希值。

public TaskWrapper<T> { 
    private T task; 
    private long delayInMillis; 
    private long key; 

    public TaskWrapper(T task, long delayInMillis, long key) { 
    this.task = task; 
    this.delayInMillis = delayInMillis; 
    this.key = key; 
    } 

    // getter, setters, and so on 

    public boolean equals(Object o) { 
     if (o == null || !(o instanceof TaskWrapper)) return false; 
     return key == ((TaskWrapper) o).key; 
    } 
} 

一個隊列裝飾器添加了類似'set'的行爲。一個隊列沒有'contains'方法，所以我拿一個額外的Set來記錄實際被請求的對象。所有更改隊列的方法都將實現，以保持內部隊列和集合之間的一致性。此快速草稿不是線程安全的，只顯示add方法。

public SetQueue<TaskWrapper> implements Queue<T> { 
    private Queue<TaskWrapper> queue; 
    private Set<TaskWrapper> set = new HashSet<TaskWrapper>(); 

    public SetQueue(Queue<TaskWrapper> queue) { 
    this.queue = queue; 
    } 

    // just to demonstrate the idea 
    public boolean add(TaskWrapper<?> task) { 
    if (set.contains(task) 
     return false; 
    boolean result = queue.add(task); 
    if (result) 
     set.add(task); 
    return result; 
    } 

_{（可能充滿錯誤的，我沒有在手的IDE這只是一個草案）}

Answer 3

一說我腦子裏浮現優雅的解決方案：使用一個線程池執行者有一個priority blocking queue作爲工作隊列。