Scala 액터는 여러 메시지를 동시에 처리 할 수 ​​있습니까?

Question

The reply 내 최근 질문에 따르면 한 배우가 자신의 메시지를 한 번에 하나씩 개 처리했습니다.. 사실입니까? 나는 명시 적으로 다음 코드가 포함되어, 그 (스칼라에서의 프로그래밍)라고 아무것도 볼 (PP를. 593)

가 [react 방법] 처리 할 수있는 메시지를 발견하면, [가] 것입니다 나중에 실행하기에 대한 해당 메시지 의 처리를 예약하고 예외

(강조 내 자신을) 던져. 두 관련 (상호 배타적) 질문 : simulatenously을 여러 메시지를 처리 ​​할 수있는 배우를 가정

1. , 어떻게 내가 (이 내가하고자하는 것입니다 경우) 한 번에 메시지 하나를 처리하기 위해 배우를 강제 할 수 있습니까? (receive를 사용하고 계십니까?) 배우를 가정
2. 메시지를 한 번에 하나씩 처리, 내가 가장 사실 가 할 수 프로세스 메시지를 동시에
이

편집 배우 구현하는 것이 방법 :하고 테스트의 비트가 보인다을 내가 틀렸다는 것과 그 배우들이 실제로 순차적이라는 것을 알 수 있습니다. 질문 2 : 답변이 필요합니다.

Answer 1

배우가 한 번에 하나의 메시지를 처리합니다. 여러 메시지를 처리하는 고전적인 패턴은 소비자 행위자 풀에 대해 하나의 코디네이터 액터를 배치하는 것입니다. react를 사용하면 소비자 풀은 클 수 있지만 여전히 적은 수의 JVM 스레드 만 사용합니다. 여기에 10 명의 소비자 풀과 하나의 코디네이터를 만드는 예가 있습니다.

import scala.actors.Actor 
import scala.actors.Actor._ 

case class Request(sender : Actor, payload : String) 
case class Ready(sender : Actor) 
case class Result(result : String) 
case object Stop 

def consumer(n : Int) = actor { 
    loop { 
    react { 
     case Ready(sender) => 
     sender ! Ready(self) 
     case Request(sender, payload) => 
     println("request to consumer " + n + " with " + payload) 
     // some silly computation so the process takes awhile 
     val result = ((payload + payload + payload) map {case '0' => 'X'; case '1' => "-"; case c => c}).mkString 
     sender ! Result(result) 
     println("consumer " + n + " is done processing " + result) 
     case Stop => exit 
    } 
    } 
} 

// a pool of 10 consumers 
val consumers = for (n <- 0 to 10) yield consumer(n) 

val coordinator = actor { 
    loop { 
    react { 
     case msg @ Request(sender, payload) => 
      consumers foreach {_ ! Ready(self)} 
      react { 
       // send the request to the first available consumer 
       case Ready(consumer) => consumer ! msg 
      } 
     case Stop => 
      consumers foreach {_ ! Stop} 
      exit 
    } 
    } 
} 

// a little test loop - note that it's not doing anything with the results or telling the coordinator to stop 
for (i <- 0 to 1000) coordinator ! Request(self, i.toString) 

이 코드는 사용 가능한 소비자를 확인하고 해당 소비자에게 요청을 보냅니다. 대안은 무작위로 소비자에게 할당하거나 라운드 로빈 스케줄러를 사용하는 것입니다.

당신이하는 일에 따라 Scala 's Futures를 사용하는 것이 더 나을 것입니다. 예를 들어, 배우가 실제로 필요하지 않다면 위의 모든 기계는 다음과 같이 쓸 수 있습니다.

import scala.actors.Futures._ 

def transform(payload : String) = {  
    val result = ((payload + payload + payload) map {case '0' => 'X'; case '1' => "-"; case c => c}).mkString 
    println("transformed " + payload + " to " + result) 
    result 
} 

val results = for (i <- 0 to 1000) yield future(transform(i.toString)) 

Answer 2

여러 가지 일을하고 싶다면 여러 배우를 사용해야합니다. 배우를 사용하는 모든 이유는 여러 독립적 인 프로세스간에 작업을 나누는 것입니다.

Answer 3

대답은 Actor이 비동기 적으로 메시지를 처리 ​​할 수 ​​없다고 생각합니다. 이러한 메시지 비동기을 처리 할 수있는 메시지를 듣고해야 Actor이 있다면, 그것은 다음과 같이 작성할 수 있습니다 :

val actor_ = actor { 

    loop { 
    react { 
     case msg => 
     //create a new actor to execute the work. The framework can then 
     //manage the resources effectively 
     actor { 
      //do work here 
     } 
     } 
    } 
    }