스칼라의 akka 배우 시스템 내의 전역 변수

Question

현재 스칼라 코드에서 akka Actor 시스템을 사용하고 있습니다. 부모 배우와 배우가 있습니다. 내가하고 싶은 일은 부모 배우에게서리스트를 시작하고 배우를 배우게하는 것입니다 :

i) 새로운 요소를 생성하고이를 부모 배우에게 보내면 누가 그 요소를리스트에 첨부 할 것입니다. ii) 언제든지 목록 요소에 액세스하십시오.

어떻게 두 번째 부분을 얻을 수 있습니까?

Answer 1

글쎄, 나는 해결책을 찾을 수 있었다.

부모 액터 내에 변수를 만들고이를 구성 매개 변수로 하위 액터에 전달하면이 변수의 모든 변경 사항을 대체하지 않으면 볼 수 있습니다. 나는 잘못된 예를 따르는 올바른 예를 들어 설명 할 것이다.

class ParentActor(/*constructors here*/) extends Actor{ 
    val list =ListBuffer[Int](1,2) 
    child = new ChildActor(list //+other constructors) 

    list=ListBuffer[Int](1,2,3) // **wrong** child will see list=List(1,2) 
    list+=3   // **right** child will see list=List(1,2,3) as wanted 

}

class ChildActor(list : ListBuffer[Int] /*++ otherconstructors here*/) extends Actor{ 

     list=ListBuffer[Int](1,2,3,4) // **wrong** parent will see list=List(1,2,3) 
     list+=4   // **right** child will see list=List(1,2,3,4) as wanted 

}

Answer 2

학부모가 답장 할 수있는 특정 메시지를 선택하여 내부 상태를 공개 할 수 있습니다. 동일한 동작이 var queue 내부에 부모를 유지하는 대신 context.become + 재귀를 사용하여 달성 될 수 있다는

import scala.collection.immutable.Queue 

    class Parent extends Actor { 
    import Parent._ 

    // TODO: start children here 

    override def receive: Receive = receiveElements(Queue.empty[Element]) 

    def receiveElements(acc: Queue[Element]): Receive = { 
     case e@Element => context.become(receiveElements(acc :+ e)) 
     case GetElements => sender ! acc 
    } 
    } 

    object Parent { 
    case class Element(s: String) 
    case object GetElements 
    } 

참고 : 아래의 예를 참조.

큐를 플러시하는 방법을 설계하지 않으면 잠재적으로 OOME이 발생할 수 있습니다.

Answer 3

너 은 메시지 전달을 사용해야합니다. 두 배우 사이에 어떤 종류의 변경 가능한 상태를 공유하면 Akka가 제공하는 모든 보장을 위반하게됩니다.

또는 대리인을 자녀와 상위 액터간에 공유 할 수 있습니다. 그러면 동기 읽기를 허용하면서 목록에 대한 업데이트가 선형화됩니다.