Java 多线程之并行流(parallelStream)
Java 8 引入了并行流的概念,可以通过 parallelStream()
方法来使用。并行流会利用多线程来处理集合中的元素。
以下是一个简单的例子,演示如何使用并行流来处理集合中的元素:
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
public class ParallelStreamExample {
public static void main(String[] args) {
List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
// 使用并行流进行计算
List<Integer> squares = numbers.parallelStream()
.map(n -> n * n) // 计算每个数的平方
.collect(Collectors.toList()); // 收集结果
// 打印结果
squares.forEach(System.out::println);
}
}
在这个例子中,parallelStream()
方法被用来创建一个并行流,然后通过 map
方法来对每个元素进行平方计算,最后通过 collect
方法收集结果。
请注意,并行流的性能优势取决于你的计算机的处理器核心数量和任务的并行度。如果你的任务不适合并行处理(如存在大量的依赖关系或者共享资源),那么并行流可能会导致性能下降。
评论已关闭