scala> (1 to 5).foreach(println(_))
1
2
3
4
5

scala> (1 to 5).par.foreach(println(_))
3
1
4
2
5

以下代码获取到参与并行计算的线程:

scala> (0 to 10000).collect{case _ => Thread.currentThread.getName}.distinct
res53: scala.collection.immutable.IndexedSeq[java.lang.String] = Vector(Thread-57)

scala> (0 to 10000).par.collect{case _ => Thread.currentThread.getName}.distinct
res54: scala.collection.parallel.immutable.ParSeq[java.lang.String] = ParVector(ForkJoinPool-1-worker-0, ForkJoinPool-1-worker-4, ForkJoinPool-1-worker-5, ForkJoinPool-1-worker-2, ForkJoinPool-1-worker-6, ForkJoinPool-1-worker-1, ForkJoinPool-1-worker-7)

相关文章:

  • 2022-12-23
  • 2021-07-08
  • 2021-06-02
  • 2022-01-03
  • 2021-05-23
  • 2021-10-24
  • 2022-03-06
  • 2021-05-17
猜你喜欢
  • 2021-08-14
  • 2021-08-22
  • 2021-12-05
  • 2021-06-21
  • 2022-01-16
  • 2021-11-14
  • 2021-08-31
相关资源
相似解决方案