Akka Future - параллельная или параллельная?

Question

Из хорошо написанный Akka Concurrency:

Как я понимаю диаграмма указывает, как numSummer и charConcat будет работать на том же потоке.

Можно ли запускать каждый Future параллельно, то есть на отдельные потоки?

Answer 1

Изображение слева is их работающие параллельно.

Пункт иллюстрации состоит в том, что метод Future.apply - это то, что начинается с исполнения, поэтому, если это не произойдет до тех пор, пока результат первого будущего не станет flatMap ed (как на картинке справа) t получить параллельное выполнение.

(Обратите внимание, что «стартовал», я имею в виду соответствующий ExecutionContext говорят о работе. Как это параллелизует другой вопрос и может зависеть от таких вещей, как размер его пула потоков.)

Эквивалент код слева:

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

и права:

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) 
     } 
    }