Akka Future - Równolegle kontra współbieżne?

Question

z dobrze napisany Akka Concurrency:

Jak Rozumiem diagram wskazuje zarówno numSummer i charConcat będzie działać na tym samym wątku.

Czy jest możliwe równoległe uruchamianie każdego Future, tj. Na oddzielnych wątkach?

Answer 1

Zdjęcie po lewej stronie: to jeżdżą równolegle.

Punktem przykładu jest to, że metoda Future.apply jest tym, co rozpoczyna wykonywanie, więc jeśli nie nastąpi, dopóki wynik pierwszej przyszłości nie zostanie zmieniony na flatMap (jak na obrazku po prawej), to nie robisz tego. t uzyskać równoległe wykonanie.

(Zauważ, że przez „skopany”, to znaczy odpowiedni ExecutionContext dowiaduje się o pracę. Jak to parallelizes to inna kwestia i może zależeć od rzeczy, jak na wielkość puli wątków.)

kod Odpowiednik dla lewej:

val numSummer = Future { ... } // execution kicked off 
val charConcat = Future { ... } // execution kicked off 
numSummer.flatMap { numsum => 
    charConcat.map { string => 
    (numsum, string) 
    } 
} 

i do prawej:

Future { ... } // execution kicked off 
    .flatMap { numsum => 
    Future { ... } // execution kicked off (Note that this does not happen until 
        // the first future's result (`numsum`) is available.) 
     .map { string => 
     (numsum, string) 
     } 
    }