Scala Futures und Multithreading

Question

Ich bin neu in Scala und ich versuche, einen Griff auf Futures zu erhalten und Multithreading

ich eine SingleThreaded Version eines Programms haben, das einige Berechnungen auf einer Matrix macht

SingleThreadCalc { 
    def run(matrix : Seq[Seq[Double]]) : Future[Seq[Seq[Double]] = Future{doMath(matrix)} 
} 

Was ich jetzt möchte, ist eine Multithread-Version davon zu machen. ist es genug, um nur einen ExecutionContext mit einer Anzahl von Threads zu übergeben?

MultiThreadCalc { 
    def run(matrix : Seq[Seq[Double]]) : Future[Seq[Seq[Double]] = 
Future{doMath(matrix)} (ExecutionContext.fromExecutor(Executors.newFixedThreadPool(10))) 

Wird sich die Berechnungslast zwischen allen Threads teilen oder geschieht dies überhaupt nicht?

Answer 1

Kurze Antwort: Nein.

Lange Antwort:

object MultiThreadCalc { 
def run(matrix : Seq[Seq[Double]]) : Future[Seq[Seq[Double]] = 
    Future{doMath(matrix)}(ExecutionContext.fromExecutor(Executors.newFixedThreadPool(10))) 
} 

Der obige Code, für jeden Aufruf von run, wird einen neuen Thread-Pool zuweisen, die nie heruntergefahren werden, und es wird verwendet werden, um eine einzelne Methode auszuführen doMath (so wird nur 1 Thread in diesem Pool verwendet werden).

Wenn Sie jetzt die Ausführung von doMath selbst parallelisieren möchten, müssen Sie die ts-Definition so ändern, dass sie parallelisierbar ist, indem Sie möglicherweise einen -Parameter verwenden und diesen in seiner Definition verwenden.

Aber wenn Sie stattdessen viele Anrufungen von doMath parallel laufen zu können, dann können Sie folgendes tun:

object MultiThreadCalc { 
    def run(matrix : Seq[Seq[Double]])(implicit ec: ExecutionContext) : Future[Seq[Seq[Double]] = Future{doMath(matrix)} 
} 

Und dann eine ExecutionContext erstellen möglicherweise ExecutionContext.fromExecutor(Executors.newFixedThreadPool(10)) auf „außen“ und es zu benutzen, wann immer Sie möchten Logik darauf ausführen.