先物のための微調整スレッドプールを設定するにはどうすればよいですか？

Question

Scalaのスレッドプールの将来の大きさはどれくらいですか？

私のScalaアプリケーションでは何百万ものものがありますが、スレッドプールを構成することでそれらを最適化するために何かできることがあるのだろうかと思います。

ありがとうございます。

Answer 1

グローバルな暗黙のExecutionContextをインポートするのではなく、先物が実行される独自のExecutionContextを指定できます。

import java.util.concurrent.Executors 
import scala.concurrent._ 

implicit val ec = new ExecutionContext { 
    val threadPool = Executors.newFixedThreadPool(1000); 

    def execute(runnable: Runnable) { 
     threadPool.submit(runnable) 
    } 

    def reportFailure(t: Throwable) {} 
} 

Answer 2

この回答はmonkjackから受け付けた回答のコメントです。しかし、この素晴らしい答えが欠けているので、私はここでそれを再転記しています。

implicit val ec = ExecutionContext.fromExecutor(Executors.newFixedThreadPool(10)) 

スレッドプールの数を変更するだけであれば、グローバルエグゼキュータを使用して、次のシステムプロパティを渡すだけです。

-Dscala.concurrent.context.numThreads=8 -Dscala.concurrent.context.maxThreads=8 

Answer 3

Scalaの先物でスレッドプールを指定するための最良の方法：

implicit val ec = new ExecutionContext { 
     val threadPool = Executors.newFixedThreadPool(conf.getInt("5")); 
     override def reportFailure(cause: Throwable): Unit = {}; 
     override def execute(runnable: Runnable): Unit = threadPool.submit(runnable); 
     def shutdown() = threadPool.shutdown(); 
    }