fork download
copy 
  1. object Main extends App {
  2.   import collection.parallel.ForkJoinTaskSupport
  3.   def parN[T](collection: Array[T], n: Int) = {
  4.     val parCollection = collection.par
  5.     parCollection.tasksupport = new ForkJoinTaskSupport(
  6.       new concurrent.forkjoin.ForkJoinPool(n))
  7.     parCollection
  8.   }
  9.   println(parN(Array(1, 2, 3), 2))
  10. }
Success #stdin #stdout 0.43s 383424KB
comments (?)
stdin
copy 
Standard input is empty
stdout
copy 
ParArray(1, 2, 3)
https://ideone.com/fwBOA0
language:
Scala (scala 2.12.8)
created:
10 years ago
visibility:
public

Share or Embed source code

Discover > Sphere Engine API

The brand new service which powers Ideone!

Discover > IDE Widget

Widget for compiling and running the source code in a web browser!