在gatling中使用scala迭代器时的并发错误

Question

我正在使用gatling来运行负载测试。我不是gatling或scala专家，但在我看来，这个特定的问题可能更多地与scala（和Akka）相关，而不是与gatling本身相关。我将从最后开始：当在不太强大的机器上高负载运行时，我偶尔会得到这样的错误：

Iterator.continually([some collection]).flatten

其中[some collection]是我试图循环遍历的集合。当许多并发线程试图访问以这种方式定义的迭代器时，它是否偶尔会失败？有没有更好的方法创建一个循环迭代器，也是线程安全的？

正如下面的“save”方法创建的租户对象（实际上，这里有更多的代码填充由get方法检索的集合，因此它实际上从不为空）：

import io.gatling.core.Predef._

object Tenants {
  type TenantKeys = Map[String, Map[String, String]]
  val key = "tenants"
  val elementKey = "tenant"
  var tenants: Iterator[Map[String, String]] = Iterator(Map[String, String]())

  def get(session: Session): TenantKeys = {
    session(key)
      .asOption[TenantKeys]
      .getOrElse(Map[String, Map[String, String]]())
  }

  def save(session: Session): Session = {
    val mapped = get(session).map(_._2).toSeq
    tenants = Iterator.continually(mapped).flatten
    session
  }
}

Answer 1

你所做的不能简单地起作用。这不是Scala的问题，而是并发编程的问题。就像Java迭代器一样，Scala迭代器不是线程安全的。

使用Gatling的feed()，这是线程安全的。