Part of the magic of Scala is that you can easily parallelize operations with features like Futures and parallel collections. When you do this, scala creates a thread pool, so that it can allocate appropriate resources.<\/p>\n
If you want to control this, you can make your own thread pool by copying the following code. This is passed to the futures API as an implicit, so it will “just work” as long as you paste it before the parallelism code (any easy way to prove this is to make the thread pool very large, and watch your machine grind to a halt)<\/p>\n
\nimplicit val ec = new ExecutionContext {\n val threadPool = Executors.newFixedThreadPool(25)\n\n def execute(runnable: Runnable) {\n threadPool.submit(runnable)\n }\n\n def reportFailure(t: Throwable) {}\n}\n<\/pre>\nYou can then give tasks to the pool with futures:<\/p>\n
\nval tasks =\n for (i <- 1 to 1000000) yield Future {\n doSomething\n }\n \nval aggr = Future.sequence(tasks)\nAwait.result(aggr, Duration.Inf)\n<\/pre>\nFor the above code to work, you'll need the following imports:<\/p>\n
\nimport scala.actors.threadpool.Executors\nimport scala.concurrent.duration.Duration\n<\/pre>\n","protected":false},"excerpt":{"rendered":"Part of the magic of Scala is that you can easily parallelize operations with features like Futures and parallel collections. When you do this, scala creates a thread pool, so that it can allocate appropriate resources. If you want to control this, you can make your own thread pool by copying the following code. This … <\/p>\n