Akka : 액터 생성 및 사서함 채우기

Question

장기간의 계산을 (단일 컴퓨터에서) 동시에 실행하려면 Akka 액터가 도움을 줄 수 있습니다.

한 가지 방법은 각 작업마다 새 액터를 스폰하는 것입니다. 예를 들어

while(true) { 
    val actor = system.actorOf(Props[ProcessingActor]) 
    (actor ? msg).map { 
     ... 
     system.stop(actor) 
    } 
} 

두 번째 아이디어는 라우터 뒤에 설정된 액터 수를 구성하는 것입니다. 그런 다음 모든 메시지를 라우터로 보내십시오.

val router = system.actorOf(Props[ProcessingActor].withRouter(RoundRobinRouter(nrOfInstances = 5))) 
while(true) { 
    (router ? msg).map { ... } 
} 

I 시스템이 과부하되면 더 인 원더 (수신 메시지의 속도는 속도 처리보다 높은)?

어느 것이 오래 걸립니까? 그리고 결국 둘 다 OOMError로 시스템을 날려 버릴 것입니까?

Answer 1

각 작업마다 새로운 Actor을 만들기 전에 Future을 사용할 수도 있습니다. 그것은 정말로 당신이 달성하기를 원하는 것에 달려 있습니다. 메모리 사용량을 최소화하면서 많은 작업을 수행하려면 액터/라우터 접근 방식을 사용해야합니다. 선물은 더 비쌉니다. 각 작업마다 Future 및 Promise의 새 인스턴스가 만들어지기 때문입니다. 그러나 실제로는 사용 사례에 따라 다르며 그 접근 방식이 더 좋습니다. 나는 많은 배우를 만들지 않을 것입니다. 실제로 배우가 필요하지 않을 때입니다. 특히 system.actorOf은 항상 새로운 오류 커널을 생성합니다.