동기화 AKKA 배우 가장 좋은 방법

Question

I가 다음과 같은 요구 사항

나는 주요 작업을 완료해야

배우 A : 메시지가가 배우 B에 전달 '특별한'경우, 주요 작업을 수행합니다 처리 한 다음 작업 배우 B 완료 : 주요 작업에 대한 특별 논리적 인 작업을 수행하고 A와 B는 함께 이것을

구현

public static class ActorA extends UntypedActor { 


    public void onReceive(Object message) { 
    if (message instanceof Work) { 
    // if message is special 
ActorRef actorB = this.getContext().actorOf(Props.create(ActorB.class,)); 
       actorB.tell(new specialTask(message.property), getSelf()); 

    } else { 
     unhandled(message); 
    } 
    } 
} 

를 완료

public static class ActorB extends UntypedActor { 


     public void onReceive(Object message) { 
     if (message instanceof specialTask) { 
     //do special task using the message that does not change the state of the message 

     } else { 
      unhandled(message); 
     } 
     } 
    } 

이 ActorA는 배우 조식 작업의 완료를 의존하지 않는

배우 B. 그러나 배우 B가 완료되면 A와 B 사이를 지나가는 메시지가 없어야하는지 확실하지 않습니다. 이것이 올바른 접근 방법입니까?

Answer 1

내가 이해할 수있는 한, 액터 B를 사용하여 A에서 계산하면 안되는 것을 계산할 수 있습니다.이 경우 A가 B에 의해 생성 된 결과에 의존하지 않으면 실제로 계산이 완료되면 B에서 A로 메시지를 보내야합니다. B로 계산 한 결과 (디스크에 쓰기, 다른 서비스에 게시하기 등)로 원하는대로 할 수 있습니다.

그러나 액터 B 사서함을 오버플로하지 않으려면 Work Pulling 또는 Reactive Stream과 같은 Akka 패턴을 A의 메시지와 함께 사용하는 것이 좋습니다. 주요 아이디어는 액터 B가 작업을 요청하도록하는 것입니다.

B가 I/O/heavy work/blocking을 수행하는 경우이 액터를 분리 된 dispatcher에서 실행하는 것이 좋습니다. 그렇지 않으면 전체 시스템이 종료 될 수 있습니다.