0

我有一个代码，我正在检查一个演员是否已经不存在，我们将创建它，但问题是我的代码正在使用未来的 OnComplete 回调，我在函数/def 中执行此操作，我只想返回 ActorRef这是我的代码

def getRegularAdminIndexMongoActor():ActorRef= {
        var actorRef:ActorRef=null
    val sel = actorSystem.actorSelection("akka://ActorSystem/user/RegularAdminIndexMongoActor");
     val future:Future[ActorRef] = sel.resolveOne().mapTo[ActorRef] 
     future.onComplete { 
          case Success(result)=>  
          if(result != null){
            log.info("actor exists" + result)
          }
          actorRef=result
          actorRef
         case Failure(e)=>
           log.warn("in failure block actor does not exists" + e)
           val regularAdminIndexMongoActor=system.actorOf(Props[RegularAdminIndexMongoActor],name = "RegularAdminIndexMongoActor")
           log.info("created a new one "+regularAdminIndexMongoActor.path.toString())
           actorRef=regularAdminIndexMongoActor      
     }
log.info("whats is in actorRef " + actorRef)
     actorRef
         }

我正在调用这样的代码

log.info("getting ref"+getRegularAdminIndexMongoActor)

and the output is 
15:33:39.082 555049 [play-internal-execution-context-1] Global$ INFO - whats in actorRef null
15:33:39.082 555049 [play-internal-execution-context-1] Global$ INFO - getting ref null
15:33:39.083 555050 [play-internal-execution-context-1] play INFO - Application started (Dev)
15:33:39.151 555118 [ForkJoinPool-4-worker-7] Global$ INFO - actor exists Actor[akka://ActorSystem/user/RegularAdminIndexMongoActor#-1022921773]

我怎样才能得到实际的 ActorRef 它给了我 null 但演员正在创建，我试图通过这样做将 ref 存储在两个块中

actorRef=result //success block
actorRef=regularAdminIndexMongoActor //failure block

我认为它在调用 onComplete 并返回 null 之前返回值，因为我在我的函数开始时初始化了变量 null 我该如何解决这个问题？请帮助我如何实现我想要的 ActorRef

4

1 回答 1

0

actorRef 是一个 var，直到 sel.resolveOne() 完成才会被分配，这可能是在您返回值之前。如果您真的想以这种方式做您正在做的事情，您可以使用

import scala.concurrent._
import scala.concurrent.duration._

Await.result(f,Duration(6000,"millis"))

等待结果将阻塞，直到未来交付或 6 秒过去。

现在，就像其他人所说的那样，这不是一个好主意。

因为您似乎正在创建那个演员，所以您可以直接访问孩子

val child = child(name)
child.getOrElse(getContext().actorOf(..., name))
于 2016-01-04T21:11:50.773 回答