在Future的成功调用中变量的作用域发生了变化

Question

我需要取回一个在未来的onSuccess块中被改变的变量。这是我的示例代码。

def futureFunction(arg:Any):Any = { 
  implicit val timeout = Timeout(10 seconds) 
  var ret:Any = None
  val f: Future[Any] = someActor ? arg
    f.onSuccess {
      case a:String => {
        ret = 1 
        println(ret) //prints "1" 
      }
      case a:Int => { 
        ret = 2 
        println(ret) //prints "2"
      }
    }
  ret //returns None
  }

ret返回为无，不会变为1，或2。那么这是否意味着onSuccess块中变量ret的值无法返回？然而，这似乎奏效了：

var a : Any = None

{
  a = 1
  println("inside "+ a ) //prints "inside 1"
}

println(a)   // prints "1"

我可以在未来的onSuccess块中做什么，以便根据未来的结果是整数还是字符串，将< code>ret的值返回为< code>1或< code>2？在这种情况下，scala的作用域规则是什么？(我用的是akka)。感谢任何帮助。谢了。

Answer 1

匿名用户

在FutureFunction中，ret在on成功处理程序运行之前返回。当这种情况发生时，ret将变成1或2，但那时已经太晚了。

您要使用的是< code>Future.map

someActor ? arg map {
  case a:String => 1
  case a:Int => 2 
}

请注意，< code>futureFunction要么必须返回一个< code>Future，要么必须在函数内部调用< code>Await.result来阻塞，直到结果可用。

Answer 2

这里的问题不是范围，而是时机。

1. 首先，将ret初始化为None
2. 然后，您将消息arg发送到someActor，该消息返回一个未来
3. 然后，设置一个函数，在将来完成时调用，如果一切顺利，该函数将在将来的某个时间点为ret赋值1或2
4. 最后，立即返回ret的值，该值仍然是None
5. 在未来的某个时刻，未来完成，您的onSuccess函数运行，更改ret的值，然后打印它。但当然，这不能返回到时间上并更改先前已返回的值

因此，为了回答您的问题，您在onResess中无法做任何事情来回到过去并更改已经返回的值。不过有两种选择。一种选择是阻止直到未来完成，然后确定是返回1还是2。另一种是返回一个Future[Int]，以便调用者可以决定是否要阻止结果。它的代码实际上比您拥有的更简单：

def futureFunction（arg：Any）：Future[Int] = { implicit val timeout = Timeout（10 seconds） val f： Future[Any] = someActor ？ arg f.map { case a：String =

如果您确实需要阻塞，您可以使用Await.result，根据您要阻塞的位置，可以在FutureFunction内部或外部使用。