import scala.collection.Parallelizable
scala> for (i <- (1 to 20).par) print(i + ",")
1,2,3,4,5,6,7,8,9,10,11,12,13,14,15,16,17,18,19,20,
scala> val ps= (2 to 30 by 1).par.map { x =>
| val a = x * x
| val b = a + 1000
| b
| }
ps: scala.collection.parallel.immutable.ParSeq[Int] = ParVector(1004, 1009, 1016, 1025, 1036, 1049, 1064, 1081, 1100, 1121, 1144, 1169, 1196, 1225, 1256, 1289, 1324, 1361, 1400, 1441, 1484, 1529, 1576, 1625, 1676, 1729, 1784, 1841, 1900)
scala> ps.toList
res30: List[Int] = List(1004, 1009, 1016, 1025, 1036, 1049, 1064, 1081, 1100, 1121, 1144, 1169, 1196, 1225, 1256, 1289, 1324, 1361, 1400, 1441, 1484, 1529, 1576, 1625, 1676, 1729, 1784, 1841, 1900)

ITPub博客

Scala Parallel 并行