import collection.
parallel.
ForkJoinTaskSupport def parN
[T
](collection
: Array
[T
], n
: Int
) = { val parCollection
= collection.
par parCollection.
tasksupport = new ForkJoinTaskSupport
( new concurrent.
forkjoin.
ForkJoinPool(n
)) parCollection
}
println(parN(Array(1, 2, 3), 2))
}
b2JqZWN0IE1haW4gZXh0ZW5kcyBBcHAgewogIGltcG9ydCBjb2xsZWN0aW9uLnBhcmFsbGVsLkZvcmtKb2luVGFza1N1cHBvcnQKICBkZWYgcGFyTltUXShjb2xsZWN0aW9uOiBBcnJheVtUXSwgbjogSW50KSA9IHsKICAgIHZhbCBwYXJDb2xsZWN0aW9uID0gY29sbGVjdGlvbi5wYXIKICAgIHBhckNvbGxlY3Rpb24udGFza3N1cHBvcnQgPSBuZXcgRm9ya0pvaW5UYXNrU3VwcG9ydCgKICAgICAgbmV3IGNvbmN1cnJlbnQuZm9ya2pvaW4uRm9ya0pvaW5Qb29sKG4pKQogICAgcGFyQ29sbGVjdGlvbgogIH0KICBwcmludGxuKHBhck4oQXJyYXkoMSwgMiwgMyksIDIpKQp9