如何处理对 Scala 集合的并发访问？

Question

我有一个 Actor，它本质上是维护一个对象列表。它具有三个基本操作，添加、更新和删除（有时删除是从 add 方法调用的，但除此之外），并且适用于单个集合。显然，该后备列表是同时访问的，添加和删除调用不断相互交错。

我的第一个版本使用了 ListBuffer，但我在某处读到它不适合并发访问。我没有遇到并发访问异常，但我确实注意到从中查找和删除对象并不总是有效，可能是由于并发性。

我正在重写它以使用 var List，但从 Scala 的默认不可变 List 中删除项目有点痛苦 - 我怀疑它是否适合并发访问。

那么，基本问题：在并发访问的情况下我应该使用什么集合类型，它是如何使用的？

（也许次要：Actor 实际上是一个多线程实体，还是这只是我的错误概念，它是否在单个线程中一次处理一个消息？）

（Tertiary：在 Scala 中，哪种集合类型最适合插入和随机访问（删除/更新）？）

编辑：致好心的回复者：对不起，我的回复太晚了，我养成了在 SO 或邮件列表上转储问题的坏习惯，然后继续处理下一个问题，暂时忘记了原来的问题。

Answer 1

Scala 的不可变集合适合并发使用。

至于演员，如here Akka 文档所述，有几件事得到保证。

• 参与者发送规则：向参与者发送消息发生在接收同一参与者之前。
• actor 后续处理规则：其中一条消息的处理发生在同一actor 处理下一条消息之前。

您不能保证同一个线程处理下一条消息，但您有保证当前消息将在下一条消息开始之前完成处理，并且在任何给定时间，只有一个线程正在执行接收方法。

这样就可以处理给定 Actor 的持久状态。关于共享数据，据我所知，最好的方法是使用不可变数据结构并尽可能依赖 Actor 模型。即“不要通过共享内存进行通信；通过通信来共享内存”。

Answer 2

您不需要同步参与者的状态。 Actor 的目的是避免复杂、容易出错和难以调试的并发编程。

Actor 模型将确保 Actor 会一一消费消息，并且您永远不会有两个线程消费同一 Actor 的消息。

Answer 3

在并发访问的情况下应该使用什么集合类型，如何使用？

查看@hbatista 的回答。

Actor 实际上是一个多线程实体，或者这只是我的错误概念，它是否在单个线程中一次处理一个消息

第二个（虽然处理消息的线程可能会改变，所以不要在线程本地数据中存储任何东西）。这就是参与者如何保持其状态的不变量。

Answer 4

看看 scala.collection.mutable.Synchronized* 特征/类。

想法是将 Synchronized 特征混合到常规可变集合中以获得它们的同步版本。

例如：

import scala.collection.mutable._
val syncSet = new HashSet[Int] with SynchronizedSet[Int]
val syncArray = new ArrayBuffer[Int] with SynchronizedBuffer[Int]