Scala 的期货线程池有多大?
我的 Scala 应用程序生成了数百万个future {}
s,我想知道是否可以通过配置线程池来优化它们。
谢谢你。
Scala 的期货线程池有多大?
我的 Scala 应用程序生成了数百万个future {}
s,我想知道是否可以通过配置线程池来优化它们。
谢谢你。
这个答案来自monkjack,来自已接受答案的评论。但是,人们可能会错过这个很棒的答案,所以我在这里重新发布。
implicit val ec = ExecutionContext.fromExecutor(Executors.newFixedThreadPool(10))
如果您只需要更改线程池计数,只需使用全局执行器并传递以下系统属性即可。
-Dscala.concurrent.context.numThreads=8 -Dscala.concurrent.context.maxThreads=8
您可以指定自己的 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) {}
}
在 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();
}
class ThreadPoolExecutionContext(val executionContext: ExecutionContext)
object ThreadPoolExecutionContext {
val executionContextProvider: ThreadPoolExecutionContext = {
try {
val executionContextExecutor: ExecutionContextExecutor = ExecutionContext.fromExecutor(Executors.newFixedThreadPool(25))
new ThreadPoolExecutionContext(executionContextExecutor)
} catch {
case exception: Exception => {
Log.error("Failed to create thread pool", exception)
throw exception
}
}
}
}