需要延迟和地图的混合

TreeMap 班级。使用可以传递比较器的构造函数。通过这种方式,可以让映射按延迟排序(因为此类实现了可比较的接口)。在将“任务”添加到映射之前,请使用containsKey方法检查密钥是否已经存在。

我就是这样理解这个问题并接受挑战的:

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”方法,因此我需要一个额外的集合来记录实际请求的对象。将实现所有更改队列的方法,以保持内部队列和集合之间的一致性。这个快速草稿不是线程安全的,只显示 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;
  }

_{(可能满是bug,我手头没有IDE。只是草稿)}

我想到的一个优雅的解决方案是:使用具有 priority blocking queue