如何为期货配置微调的线程池?

问题描述

Scala 的期货线程池有多大?

How large is Scala's thread pool for futures?

我的 Scala 应用程序生成了数百万个 future {}，我想知道我是否可以通过配置线程池来优化它们.

My Scala application makes many millions of future {}s and I wonder if there is anything I can do to optimize them by configuring a thread pool.

谢谢.

推荐答案

您可以指定自己的 ExecutionContext 来运行您的期货，而不是导入全局隐式 ExecutionContext.

You can specify your own ExecutionContext that your futures will run in, instead of importing the global implicit 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) {}
}

这篇关于如何为期货配置微调的线程池?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！