当前位置： 首页 > article >正文

stream流常用方法

article 2025/2/21 23:38:13

1.reduce

在Java中，可以使用Stream API的reduce方法来计算一个整数列表的乘积。reduce方法是一种累积操作，它可以将流中的元素组合起来，返回单个结果。对于计算乘积，你需要提供一个初始值（通常是1，因为乘法的单位元是1）和一个二元操作符（这里是乘法操作）。

以下是一个示例代码，演示如何使用reduce方法来计算一个整数列表的乘积：

	import java.util.Arrays;
	import java.util.List;
	import java.util.Optional;
 
	public class ProductCalculator {
    public static void main(String[] args) {
        List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
 
        // 使用reduce方法计算乘积
        Optional<Integer> product = numbers.stream()
                                           .reduce(1, (a, b) -> a * b);
 
        // 由于reduce返回的是Optional，需要处理可能的空值
        if (product.isPresent()) {
            System.out.println("The product of the list is: " + product.get());
        } else {
            System.out.println("The list is empty or some error occurred.");
        }
    }
}
``
在这个例子中：

numbers.stream() 创建一个整数列表的流。
.reduce(1, (a, b) -> a * b) 从1开始，将流中的每个元素依次乘以当前的结果。这里1是初始值，(a, b) -> a * b是累积操作（即将当前结果a与下一个元素b相乘）。
reduce方法返回一个Optional<Integer>，因为流操作可能会返回一个空的结果（例如，当流为空时）。
使用if (product.isPresent())来检查乘积是否存在，如果存在则打印乘积，否则打印错误信息。
此外，如果确定列表不会为空，你也可以直接使用orElse方法来提供一个默认值，从而简化代码：

```java
	
		public class ProductCalculator {
   		 public static void main(String[] args) {
        	List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
 
     	   // 使用reduce方法计算乘积，并提供默认值
      	  int product = numbers.stream()
                            	 .reduce(1, (a, b) -> a * b)
                            	 .orElse(1); // 如果列表为空，返回1作为默认值
 
        	System.out.println("The product of the list is: " + product);
    	}
	}

在这个改进的版本中，如果流为空，orElse(1)会确保返回一个默认值1，而不是处理Optional对象。

collect和collector.xx


		 List<Student> students = Arrays.asList(
                new Student("Alice", 20),
                new Student("Bob", 22),
                new Student("Charlie", 20),
                new Student("David", 22)
        );
        //Arrays,collections




        //按学生的年龄分组。
        //
        //打印每个年龄对应的学生姓名列表。
        students.stream()
                .collect(Collectors.groupingBy(Student::getAge))//这里得到一个Map<Integer,list<String>>,然后利用foreach遍历Map集合
                .forEach((age, studentsInAge) -> {
                    System.out.println("Age: " + age);
                    studentsInAge.forEach(student -> System.out.println("  Name: " + student.getName()));
                });
                ```

###  附：Map集合使用foreach遍历

```java
	Map<String, Integer> map = new HashMap<>();
map.put("Apple", 1);
map.put("Banana", 2);
map.put("Cherry", 3);

map.forEach((key, value) -> {
    System.out.println("Key: " + key + ", Value: " + value);
});

在 Java 的 Stream API 中，map 方法用于将流中的每个元素转换为另一种形式。你可以使用 map 方法来对流中的每个元素进行某种操作，并返回一个新的流，其中包含转换后的元素。

stream流的map方法基本用法

map 方法的签名如下：

<R> Stream<R> map(Function<? super T, ? extends R> mapper)
  • T 是流中当前元素的类型。
  • R 是转换后的新元素的类型。
  • Function<T, R> 是一个函数接口，它接受一个 T 类型的参数并返回一个 R 类型的结果。

示例

  1. 基本示例：将整数列表中的每个元素平方
List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);
List<Integer> squares = numbers.stream()
                               .map(n -> n * n) // 将每个元素平方
                               .collect(Collectors.toList());
System.out.println(squares); // 输出 [1, 4, 9, 16, 25]
  1. 将字符串列表中的每个元素转换为大写
List<String> words = Arrays.asList("apple", "banana", "grape", "kiwi", "orange");
List<String> upperCaseWords = words.stream()
                                   .map(String::toUpperCase) // 将每个字符串转换为大写
                                   .collect(Collectors.toList());
System.out.println(upperCaseWords); // 输出 [APPLE, BANANA, GRAPE, KIWI, ORANGE]
  1. 将对象列表中的某个属性提取出来
List<Student> students = Arrays.asList(
    new Student("Alice", 20),
    new Student("Bob", 22),
    new Student("Charlie", 20),
    new Student("David", 22)
);

List<String> names = students.stream()
                             .map(Student::getName) // 提取每个学生的姓名
                             .collect(Collectors.toList());
System.out.println(names); // 输出 [Alice, Bob, Charlie, David]
  1. 将对象列表中的某个属性转换为另一个对象
List<Person> people = Arrays.asList(
    new Person("Alice", 20),
    new Person("Bob", 17),
    new Person("Charlie", 25)
);

List<String> upperCaseNames = people.stream()
                                    .filter(person -> person.getAge() > 18) // 过滤年龄大于18的人
                                    .map(person -> person.getName().toUpperCase()) // 将名字转换为大写
                                    .collect(Collectors.toList());
System.out.println(upperCaseNames); // 输出 [ALICE, CHARLIE]

完整代码示例

以下是你的代码中未完成的部分，以及如何使用 map 方法来完成它：

import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;

public class Test01 {
    public static void main(String[] args) {
        // 其他代码...

        System.out.println("-----------------------------------------");
        // 过滤出所有年龄大于18岁的人。
        // 将他们的名字转换为大写。
        // 收集到一个新的列表中并打印。
        List<Person> people = Arrays.asList(
                new Person("Alice", 20),
                new Person("Bob", 17),
                new Person("Charlie", 25)
        );
        
        List<String> upperCaseNames = people.stream()
                                            .filter(person -> person.getAge() > 18) // 过滤年龄大于18的人
                                            .map(person -> person.getName().toUpperCase()) // 将名字转换为大写
                                            .collect(Collectors.toList()); // 收集到新的列表
        System.out.println(upperCaseNames); // 输出 [ALICE, CHARLIE]
    }
}

class Person {
    String name;
    int age;

    public Person() {
    }

    public Person(String name, int age) {
        this.name = name;
        this.age = age;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
}

解释

  • filter(person -> person.getAge() > 18)：过滤出年龄大于18岁的 Person 对象。
  • map(person -> person.getName().toUpperCase())：将每个 Person 对象的名字转换为大写。
  • collect(Collectors.toList())：将转换后的名字收集到一个新的 List 中。

## collector

Collectors 是 Java 8 中 Stream API 提供的一个强大工具，用于将流中的元素收集到集合或其他数据结构中。以下是一些常见的 Collectors 用法示例：

1. 收集到 List

将流中的元素收集到一个 List 中。

List<String> words = Arrays.asList("apple", "banana", "grape", "kiwi", "orange");
List<String> longWords = words.stream()
                              .filter(word -> word.length() > 5)
                              .collect(Collectors.toList());
System.out.println(longWords); // 输出 [banana, orange]

2. 收集到 Set

将流中的元素收集到一个 Set 中，自动去重。

List<String> words = Arrays.asList("apple", "banana", "apple", "kiwi", "banana");
Set<String> uniqueWords = words.stream()
                               .collect(Collectors.toSet());
System.out.println(uniqueWords); // 输出 [banana, apple, kiwi]

3. 收集到 Map

将流中的元素收集到一个 Map 中，键为元素本身，值为元素的长度。

List<String> words = Arrays.asList("apple", "banana", "grape", "kiwi", "orange");
Map<String, Integer> wordLengthMap = words.stream()
                                          .collect(Collectors.toMap(
                                              word -> word, // Key: 单词本身
                                              String::length // Value: 单词长度
                                          ));
System.out.println(wordLengthMap); // 输出 {apple=5, banana=6, grape=5, kiwi=4, orange=6}

4. 分组（Grouping By）

将流中的元素按某个属性分组。

List<Student> students = Arrays.asList(
    new Student("Alice", 20),
    new Student("Bob", 22),
    new Student("Charlie", 20),
    new Student("David", 22)
);

Map<Integer, List<Student>> studentsByAge = students.stream()
    .collect(Collectors.groupingBy(Student::getAge));

studentsByAge.forEach((age, studentList) -> {
    System.out.println("Age: " + age);
    studentList.forEach(student -> System.out.println("  Name: " + student.getName()));
});

5. 分区（Partitioning By）

将流中的元素按某个条件分为两个分区（true 和 false）。

List<String> words = Arrays.asList("apple", "banana", "grape", "kiwi", "orange");
Map<Boolean, List<String>> partitionedWords = words.stream()
    .collect(Collectors.partitioningBy(word -> word.length() > 5));

System.out.println("Long words: " + partitionedWords.get(true)); // 输出 [banana, orange]
System.out.println("Short words: " + partitionedWords.get(false)); // 输出 [apple, grape, kiwi]

6. 连接字符串（Joining）

将流中的字符串元素连接成一个字符串。

List<String> words = Arrays.asList("apple", "banana", "grape", "kiwi", "orange");
String joinedWords = words.stream()
                          .collect(Collectors.joining(", "));
System.out.println(joinedWords); // 输出 apple, banana, grape, kiwi, orange

7. 统计汇总（Summarizing）

对流中的元素进行统计汇总，如求和、平均值、最大值、最小值等。

List<Integer> numbers = Arrays.asList(3, 12, 8, 15, 20, 7, 10);
IntSummaryStatistics stats = numbers.stream()
    .collect(Collectors.summarizingInt(Integer::intValue));

System.out.println("Sum: " + stats.getSum()); // 输出 75
System.out.println("Average: " + stats.getAverage()); // 输出 10.714285714285714
System.out.println("Max: " + stats.getMax()); // 输出 20
System.out.println("Min: " + stats.getMin()); // 输出 3

8. 自定义收集器

通过 Collector.of 自定义收集器。

List<String> words = Arrays.asList("apple", "banana", "grape", "kiwi", "orange");
String concatenated = words.stream()
    .collect(Collector.of(
        StringBuilder::new, // Supplier: 创建一个新的 StringBuilder
        StringBuilder::append, // Accumulator: 将每个元素添加到 StringBuilder
        StringBuilder::append, // Combiner: 合并两个 StringBuilder（用于并行流）
        StringBuilder::toString // Finisher: 将 StringBuilder 转换为字符串
    ));
System.out.println(concatenated); // 输出 applebananagrapekiwiorange

http://www.kler.cn/a/553681.html

相关文章：

  • mac os设置jdk版本
  • DeepSeek-V3模型底层架构的核心技术一（多Token预测（MTP）技术）
  • 动态规划之背包问题
  • 力扣-二叉树-235 二叉搜索树的最近公共祖先
  • 位运算，双指针，二分，排序算法
  • 一台服务器将docker image打包去另一天服务器安装这个镜像
  • 2025年02月18日Github流行趋势
  • 【基础架构篇九】《DeepSeek模型版本管理：Git+MLflow集成实践》
  • MySQL面试考点汇总
  • 基于SpringBoot+Vue的老年人体检管理系统的设计与实现(源码+SQL脚本+LW+部署讲解等)
  • 变相提高大模型上下文长度-RAG文档压缩-3.优化map-reduce(reranker过滤+社区聚类)
  • 零基础学QT、C++（三）魔改QT组件库（付源码）
  • 闲鱼IP属地为何频繁变化：深入解析与应对策略
  • Redis为什么速度快、性能高？
  • 基于YOLO11深度学习的果园苹果检测与计数系统设计与实现【python源码+Pyqt5界面+数据集+训练代码】
  • Transformer多头注意力并行计算原理与工业级实现：从数学推导到PyTorch工程优化
  • WebAssembly：现代Web开发的革命性技术
  • vue3和vue2的组件开发有什么区别
  • MySQL标识列
  • 内核数据结构用法（5）hlist