<dependency> <groupId>org.scala-lang</groupId> <artifactId>scala-library</artifactId> <version>2.13.5</version> </dependency> import scala.collection.parallel.ParSeq; import scala.collection.parallel.ForkJoinTaskSupport; import scala.collection.parallel.ForkJoinTaskSupport; import scala.collection.parallel.ParSeq; public class ParallelCollectionsExample { public static void main(String[] args) { ParSeq<Integer> numbers = ParSeq.range(1, 1000); ForkJoinTaskSupport taskSupport = new ForkJoinTaskSupport(new scala.concurrent.forkjoin.ForkJoinPool(4)); numbers.tasksupport().set(taskSupport); int sum = numbers.mapToInt(x -> x * 2).sum(); System.out.println("Sum: " + sum); } }


上一篇:
下一篇:
切换中文