Các diễn viên Scala có thể xử lý đồng thời nhiều thư không?

Question

The reply cho câu hỏi gần đây của tôi cho biết rằng một diễn viên đã xử lý thông báo của mình từng thư một. Điều này có đúng không? Tôi thấy không có gì là rõ ràng nói rằng (trong Lập trình trong Scala), trong đó có chứa đoạn mã sau (tr. 593)

Nếu [phương pháp react] tìm thấy một thông điệp có thể được xử lý, [nó] sẽ lên lịch xử lý tin nhắn đó để thực hiện sau và ném một ngoại lệ

(Nhấn mạnh của riêng tôi). Hai câu hỏi có liên quan (và loại trừ lẫn nhau):

1. Giả sử một diễn viên có thể xử lý nhiều thông điệp một cách tương tự, làm cách nào để buộc diễn viên xử lý tin nhắn 1 một lần (nếu đây là điều tôi muốn làm)? (Sử dụng receive?)
2. Giả sử một diễn viên xử lý thông điệp cùng một lúc, làm thế nào tôi sẽ thực hiện tốt nhất là một diễn viên mà trong thực tế thể thông điệp quá trình đồng thời

chỉnh sửa: làm một chút thử nghiệm dường như phát hiện ra rằng tôi sai và các diễn viên đó thực sự là tuần tự. Vì vậy, đó là câu hỏi số 2 mà tôi cần trả lời

Answer 1

diễn viên xử lý một thông điệp tại một thời điểm. Các mô hình cổ điển để xử lý nhiều thông điệp là có một diễn viên điều phối viên phía trước cho một nhóm các diễn viên tiêu dùng. Nếu bạn sử dụng phản ứng thì hồ bơi tiêu dùng có thể lớn nhưng sẽ chỉ sử dụng một số lượng nhỏ các luồng JVM. Đây là một ví dụ mà tôi tạo ra một nhóm gồm 10 người tiêu dùng và một điều phối viên ở phía trước cho họ.

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) 

Mã này kiểm tra xem người tiêu dùng nào có sẵn và gửi yêu cầu đến người tiêu dùng đó. Các giải pháp thay thế chỉ được gán ngẫu nhiên cho người tiêu dùng hoặc sử dụng một bộ lập lịch vòng tròn.

Tùy thuộc vào những gì bạn đang làm, bạn có thể được phục vụ tốt hơn với tương lai của Scala. Ví dụ: nếu bạn không thực sự cần diễn viên thì tất cả các máy móc ở trên có thể được viết là

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

Nếu bạn muốn làm nhiều việc thì bạn nên sử dụng nhiều diễn viên. Toàn bộ lý do để sử dụng diễn viên là phân chia công việc giữa nhiều quy trình độc lập.

Answer 3

Tôi nghĩ rằng câu trả lời là một Actor không thể xử lý thư một cách không đồng bộ. Nếu bạn có một Actor cần được lắng nghe những thông điệp có những thông điệp có thể bị xử lý không đồng bộ, sau đó nó có thể được viết như thế này:

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 
     } 
     } 
    } 
    }