scala
import scala.collection.parallel.CollectionConverters._
val data = Seq(1, 2, 3, 4, 5)
val parallelData = data.par
scala
scala
val customOperation = parallelData.aggregate(0)(
(acc, element) => acc + element * 2,
(acc1, acc2) => acc1 + acc2
)
scala
parallelData.tasksupport = new ForkJoinTaskSupport(new ForkJoinPool(4))
