对于受过Scala教育的人来说,这可能是一个简单的问题,但我仍然是初学者;)
我有一个基础演员,他将任务分派给多个工人演员,并将其结果回复到阻塞的外部调用!?
a = new a
a.start
println(a !? "12345")
class a extends Actor {
def act = {
loop {
react {
case msg =>
val result = worker_actor_1 !? msg
result += worker_actor_2 !? msg
result += worker_actor_3 !? msg
// So I just have multiple workers who should do stuff in parallel and the aggregated result should be returned to the calling function
reply(result)
}
现在我不知道如何在阻塞调用中真正并行化工作角色,因为最后我必须回复()。调用实体不是演员,只是一个普通的班级。