Scala：：PriorityQueue=>更新特定项的优先级

Question

我已经实现了从head中提取item，更新它的优先级并将它放回队列的例程（使用AtomicReference）

def head(): Entry = {
  def takeAndUpdate(e: Entry, success: Boolean): Entry = {
    if (success) {
      return e
    }
    val oldQueue = queueReference.get()
    val newQueue = oldQueue.clone()
    val item = newQueue.dequeue().increase()
    newQueue += item
    takeAndUpdate(item.e, queueReference.compareAndSet(oldQueue, newQueue))
  }
  takeAndUpdate(null, false)
}

现在我需要找出队列中的任意条目，更改它的优先级并将其放回队列中。看来PriorityQueue不支持这一点，那么我应该使用哪个类来完成期望的行为呢？

Answer 1

使用不可变的树映射(immutable.treemap)来完成此操作。您必须以某种方式找到您想要的条目--最好的方法是将用于查找条目的信息(key)与一个键相关联，并将您希望与映射中的值一起返回的实际条目（将此entry)相关联。

使用treeReference重命名queueReference。在创建集合的代码部分，使用immutable.treemap[Key,Entry]( <list of="" elements=""> ) 。

然后像这样修改代码：

def updateKey(k: Key) {
  @annotation.tailrec def update(): (Key, Entry) = {
    val oldTree = treeReference.get()
    val entry = oldTree(k)
    val newPair = modifyHoweverYouWish(k, entry)
    val newTree = (oldTree - k) + newPair
    if (treeReference.compareAndSet(oldTree, newTree)) newPair
    else update()
  }
  update()
}

或者，您可以使用immutable.treeSet-如果您知道对entry对象的确切引用，您可以使用它通过-移除元素，如上所述，然后在调用increase()后将其添加回来。代码几乎是一样的。