Scala的collection.mutable.PriorityQueue线程是否安全？

我们来看一下！ scala.collection.mutable.PriorityQueue uses

private val resarr = new ResizableArrayAccess[A]

其中ResizableArrayAccess在PriorityQueue中为defined

private class ResizableArrayAccess[A] extends AbstractSeq[A] with ResizableArray[A] with Serializable {

从那里,转到scala.collection.mutable.ResizableArray,显然这不是线程安全的,例如通过查看update方法：

protected var array: Array[AnyRef] = new Array[AnyRef](math.max(initialSize,1))
 // ... snip ... //
def update(idx: Int,elem: A) {
  if (idx >= size0) throw new IndexOutOfBoundsException(idx.toString)
  array(idx) = elem.asInstanceOf[AnyRef]
}

因此,我们对不可变的var进行了无保护的访问,并且不鼓励使用来自多个线程的scala.collection.mutable.PriorityQueue.

如果你真的需要从多个线程使用它并且并发性并不重要,你可以使用某些同步意义,例如scala.util.SyncVar可以防止竞争条件等并发问题.否则使用其他数据结构会更好.