Scala Будущее не работает, как я ожидаю

Question

Что я хочу сделать, это использовать Future, чтобы открыть поток для обработки задачи async, которая может быть вызвана часто.

Но в async task. Я также вызываю две функции Future, чтобы получить информацию из разных источников данных.

Я пишу программу для имитации этой ситуации.

import scala.concurrent.{ExecutionContext, Future} 
import scala.util.{Success, Failure} 
import scala.util.control.Breaks 
import ExecutionContext.Implicits.global 
object AsyncTest { 


    def main(args: Array[String]) { 
    try { 
     println("Run...") 
     aSyncTask 
    } catch { 
     case e => e.printStackTrace() 
    } 

    Thread.sleep(999999) 
    } 
    //dataSource1 
    def getInfo1 : Future[String] = Future{ 
    "A" 
    } 
    //dataSource2 let it wait 3 seconds... 
    def getInfo2 : Future[String] = Future{ 
    Thread.sleep(3000) 
    "B" 
    } 

    def aSyncTask = Future{ 
    getInfo1 
    getInfo2 

    var result1 : String = null 
    var result2 : String = null 

    getInfo1.onComplete{ 
     case Success(value) => result1 = value 
     case Failure(t) => println { 
     "An error has occured: " + t.getMessage 
     } 
    } 

    getInfo2.onComplete{ 
     case Success(value) => result2 = value 
     case Failure(t) => println { 
     "An error has occured: " + t.getMessage 
     } 
    } 
    /*I want to wait both Future function completed then 
     I can do some business logic */ 
    Breaks.breakable{ 
     while (true) { 
     if (result1 != null && result2 != null) 
      Breaks.break 
     } 
    } 

    println("----------------------") 
    println("result1:"+result1) 
    println("result2:"+result2) 
    println("----------------------") 
    } 

} 

После того как я компиляции и запуска этой программы, она выдавала ничего. просто подождите.

Run... 

Я ожидал, что я мог видеть выход:

Run... 
---------------------- 
result1:A 
result2:B 
---------------------- 

Итак, я добавил код в while цикле для отладки.

Breaks.breakable{ 
     while (true) { 
     println(result1) 
     println(result2) 
     if (result1 != null && result2 != null) 
      Breaks.break 
     } 
    } 

Тогда выход:

Run... 
A 
null 
A 
null 
A 
null 
A 
null 
A 
null 
(After 3 seconds...) 
A 
B 
---------------------- 
result1:A 
result2:B 
---------------------- 

Что происходит ?? Я просто добавлю два println, чтобы увидеть две переменные.

Почему программа может быть выполнена так, как я ожидал, когда я ее печатаю?

Answer 1

Future был создан, чтобы быть компонуемы, поэтому я рискну и предположим, что вы хотите что-то вроде этого:

// Important to initialize them outside of for comprehension 
val (f1, f2) = (getInfo1, getInfo2) 
val ab: Future[(String, String)] = 
    for { 
    r1 <- f1 
    r2 <- f2 
    } yield (r1, r2) // Do whatever you want to do with r1 and r2 

println(Await.result(ab, Duration(10000, MILLISECONDS)))