akka Actor 中的可变集合返回 NullPointerException-解网

问：

我有一个参与者，每次它收到来自 Web 套接字的更新时，它都会调用 websocket 并更新地图。执行组件在命令中的另一个点使用相同的地图。

class MyActor(broker: InMemoryBroker) extends Actor {
val myMap: TrieMap[String, String] = new TrieMap[String, String]()

//Gets a response every 1 second 
webSocket.get(onReponse= r=> myMap(r.key) = r.value)


def receive()={
 case MyCommand(key)=>
   if(myMap.get(key).isDefined){     //Null pointer exception is thrown here
       //Do stuff
   }
}

我期望线程安全并且没有此类问题。有什么建议吗？TrieMap

斯卡拉收集阿卡演员可变

class MyActor(broker: InMemoryBroker) extends Actor {
  val myMap: TrieMap[String, String] = new TrieMap[String, String]()

  private case class UpdateMap(r: ???)

  //Gets a response every 1 second 
  webSocket.get(onReponse = r => self ! UpdateMap(r))

  def receive() = {
    case UpdateMap(r) =>
      myMap(r.key) = r.value

    case MyCommand(key) =>
      if (myMap.get(key).isDefined) { //Null pointer exception is thrown here
        //Do stuff
      }
  }
}

使用该方法，一次只能从单个线程访问。TrieMap

此外，该测试最好按以下方式完成：

myMap.get(key).foreach{ value =>
  ???
}

上一个：如何在 scala 中更改 set 的元素

下一个：在 scala 中使用 for 循环（索引）将值插入到 Mutable List 中

akka Actor 中的可变集合返回 NullPointerException

Mutable collections in akka Actor return NullPointerException

评论