Java8 Stream常见用法

Stream流的常见用法:

1.利用stream流特性把数组转list集合

//定义一个数组
Integer[] array = {5,2,1,6,4,3};
//通过stream特性把数组转list集合
List<Integer> list = Arrays.stream(array).collect(Collectors.toList());
//打印结果
System.out.println(list);

输出结果为:

2.利用stream流特性取出list集合中的最大值

//定义一个数组
Integer[] array = {5,2,1,6,4,3};
//通过stream特性把数组转list集合
List<Integer> list = Arrays.stream(array).collect(Collectors.toList());
//通过stream特性获取集合中的最大值
Integer max = list.stream().max(Comparator.comparing(Integer::new)).get();
//打印结果
System.out.println(max);

输出结果为:

3.利用stream流特性取出list集合中的最小值

//定义一个数组
Integer[] array = {5,2,1,6,4,3};
//通过stream特性把数组转list集合
List<Integer> list = Arrays.stream(array).collect(Collectors.toList());
//通过stream特性获取集合中的最
Integer min= list.stream().min(Comparator.comparing(Integer::new)).get();
//打印结果
System.out.println(min);

输出结果为:

4.利用stream流特性取出list集合中大于3的值

//定义一个数组
Integer[] array = {5,2,1,6,4,3};
//通过stream特性把数组转list集合
List<Integer> list = Arrays.stream(array).collect(Collectors.toList());
//通过stream特性获取集合中大于3的所有值
List<Integer> conditions =

list.stream().filter(value -> value > 3).collect(Collectors.toList());
//打印结果
System.out.println(conditions);

输出结果:

5.利用stream流特性取出list集合中小于3的值

//定义一个数组
Integer[] array = {5,2,1,6,4,3};
//通过stream特性把数组转list集合
List<Integer> list = Arrays.stream(array).collect(Collectors.toList());
//通过stream特性获取集合中小于3的所有值
List<Integer> conditions = list.stream().filter(value -> value < 3).collect(Collectors.toList());
//打印结果
System.out.println(conditions);

输出结果:

6.利用stream流特性取出list集合中不等于3的值

//定义一个数组
Integer[] array = {5,2,1,6,4,3};
//通过stream特性把数组转list集合
List<Integer> list = Arrays.stream(array).collect(Collectors.toList());
//通过stream特性获取集合中不等于3的值
List<Integer> conditions = list.stream().filter(value -> value != 3).collect(Collectors.toList());
//打印结果
System.out.println(conditions);

输出结果:

7.利用stream流特性计算list集合中大于1的数量

//定义一个数组
Integer[] array = {5,2,1,6,4,3};
//通过stream特性把数组转list集合
List<Integer> list = Arrays.stream(array).collect(Collectors.toList());
//通过stream特性获取集合中大于1数量
long count = list.stream().filter(value -> value > 1).count();
//打印结果
System.out.println(count);

输出结果:

8.利用stream流特性计算list集合中等于2的数量

//定义一个数组
Integer[] array = {5,2,1,6,4,3};
//通过stream特性把数组转list集合
List<Integer> list = Arrays.stream(array).collect(Collectors.toList());
//通过stream特性获取集合中等于2的数量
long count = list.stream().filter(value -> value == 2).count();
//打印结果
System.out.println(count);

输出结果:

9.利用stream流特性去除list集合中重复的数据

//定义一个数组
Integer[] array = {5,5,2,2,1,1,6,6,4,4,3,3};
//通过stream特性把数组转list集合
List<Integer> list = Arrays.stream(array).collect(Collectors.toList());
//通过stream特性去除集合中重复的数据
List<Integer> collects = list.stream().distinct().collect(Collectors.toList());
//打印结果
System.out.println("去除前的数据:" + list + "\n去重后的数据:" + collects);

输出结果:

10.利用stream流特性截取list集合中前两个的数据

//定义一个数组
Integer[] array = {5,2,1,6,4,3};
//通过stream特性把数组转list集合
List<Integer> list = Arrays.stream(array).collect(Collectors.toList());
//通过stream特性截取集合中前两个数值
List<Integer> collects = list.stream().limit(2).collect(Collectors.toList());
//打印结果
System.out.println("截取到的数据:" + collects);

输出结果:

11.利用stream流特性跳过list集合中前两个数据

//定义一个数组
Integer[] array = {5,2,1,6,4,3};
//通过stream特性把数组转list集合
List<Integer> list = Arrays.stream(array).collect(Collectors.toList());
//通过stream特性跳过集合中前两个数值
List<Integer> collects = list.stream().skip(2).collect(Collectors.toList());
//打印结果
System.out.println("跳过前两个值后的数据:" + collects);

输出结果:

12.利用stream流特性遍历list集合中每一个元素

//定义一个数组
Integer[] array = {5,2,1,6,4,3};
//通过stream特性把数组转list集合
List<Integer> list = Arrays.stream(array).collect(Collectors.toList());
//通过stream特性遍历集合中每一个元素
list.stream().forEach(System.out::println);

输出结果:

13.利用stream流特性计算list集合中数值的平均值

//定义一个数组
Integer[] array = {5,2,1,6,4,3};
//通过stream特性把数组转list集合
List<Integer> list = Arrays.stream(array).collect(Collectors.toList());
//通过stream特性计算集合中数值的平均值
double average = list.stream().mapToInt(Integer::new).average().orElse(0);
//打印结果
System.out.println("计算后的平均值:" + average);

输出结果:

14.利用stream流特性计算list集合中数值的总和

//定义一个数组
Integer[] array = {5,2,1,6,4,3};
//通过stream特性把数组转list集合
List<Integer> list = Arrays.stream(array).collect(Collectors.toList());
//通过stream特性计算集合中数值的总和
int sum = list.stream().mapToInt(Integer::new).sum();
//打印结果
System.out.println("计算后的总和:" + sum);

输出结果:

15.利用stream流特性升序排列list集合中所有元素

//定义一个数组
Integer[] array = {5,2,1,6,4,3};
//通过stream特性把数组转list集合
List<Integer> list = Arrays.stream(array).collect(Collectors.toList());
//通过stream特性升序排列集合中的所有元素
List<Integer> collects = list.stream().sorted().collect(Collectors.toList());
//打印结果
System.out.println("升序排列后的集合:" + collects);

输出结果:

16.利用stream流特性降序排列list集合中所有元素

//定义一个数组
Integer[] array = {5,2,1,6,4,3};
//通过stream特性把数组转list集合
List<Integer> list = Arrays.stream(array).collect(Collectors.toList());
//通过stream特性降序排列集合中的所有元素
List<Integer> collects = list.stream().sorted(Comparator.reverseOrder()).collect(Collectors.toList());
//打印结果
System.out.println("降序排列后的集合:" + collects);

输出结果:

结合实际拓展使用:

1、处理Person对象列表,及一些常见的数据操作

创建一个Person类,它具有姓名、年龄和性别属性。我们要处理一个包含多个Person对象的列表,并进行一些常见的数据操作。以下是使用Java 8的Stream常用用法处理这个复杂数据的示例代码:

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

public class Stream {


    public static void main(String[] args) {
        //在集合中添加几组数据
        List<Person> persons = Arrays.asList(
                new Person("John", 25, Gender.MALE),
                new Person("Jane", 30, Gender.FEMALE),
                new Person("Tom", 20, Gender.MALE),
                new Person("Susan", 28, Gender.FEMALE),
                new Person("Mike", 35, Gender.MALE)
        );

        // 使用Stream的常用用法

        // 1. 按年龄升序排列,并获取姓名列表
        List<String> sortedNames = persons.stream()
                .sorted((p1, p2) -> p1.getAge() - p2.getAge())
                .map(Person::getName)
                .collect(Collectors.toList());
        System.out.println(sortedNames);

        // 2. 获取所有年龄大于25岁的人的姓名列表
        List<String> namesAbove25 = persons.stream()
                .filter(p -> p.getAge() > 25)
                .map(Person::getName)
                .collect(Collectors.toList());
        System.out.println(namesAbove25);

        // 3. 统计男性和女性的人数
        long maleCount = persons.stream()
                .filter(p -> p.getGender() == Gender.MALE)
                .count();
        long femaleCount = persons.stream()
                .filter(p -> p.getGender() == Gender.FEMALE)
                .count();
        System.out.println("Male count: " + maleCount);
        System.out.println("Female count: " + femaleCount);

        // 4. 按性别分组
        Map<Gender, List<Person>> personsByGender = persons.stream()
                .collect(Collectors.groupingBy(Person::getGender));
        System.out.println(personsByGender);

        // 5. 计算年龄的平均值
        double averageAge = persons.stream()
                .mapToInt(Person::getAge)
                .average()
                .orElse(0);
        System.out.println("Average age: " + averageAge);
    }
}

//定义一个人物类
class Person {
    private String name;
    private int age;
    private Gender gender;

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

    public String getName() {
        return name;
    }

    public int getAge() {
        return age;
    }

    public Gender getGender() {
        return gender;
    }

    @Override
    public String toString() {
        return "Person{" +
                "name='" + name + '\'' +
                ", age=" + age +
                ", gender=" + gender +
                '}';
    }
}
//定义一个枚举类
enum Gender {
    MALE, FEMALE
}

这段代码使用了Stream的排序、映射、过滤、计数、分组和统计等常用操作,展示了如何在处理复杂数据时利用Stream提供的功能。根据实际需要,可以组合使用这些操作来完成更复杂的数据处理任务。

2、学生老师和课程,及一些常见的数据操作

创建一个包含学生、老师和课程的复杂数据结构。学生和老师都有姓名和年龄属性,课程有名称和标签属性。我们要处理这个复杂数据结构,并进行一些常见的数据操作。以下是使用Java 8的Stream常用用法处理这个复杂数据的示例代码:

import java.util.*;
import java.util.stream.Collectors;
public class Stream {
    public static void main(String[] args) {
        // 创建学生
        Student student1 = new Student("John", 20);
        Student student2 = new Student("Jane", 22);
        Student student3 = new Student("Tom", 23);
        List<Student> students = Arrays.asList(student1, student2, student3);

        // 创建老师
        Teacher teacher1 = new Teacher("Amy", 35);
        Teacher teacher2 = new Teacher("Bob", 40);
        List<Teacher> teachers = Arrays.asList(teacher1, teacher2);

        // 创建课程
        Course course1 = new Course("Math", "science");
        Course course2 = new Course("English", "language");
        Course course3 = new Course("Physics", "science");
        List<Course> courses = Arrays.asList(course1, course2, course3);

        // 学生选课
        student1.selectCourse(course1);
        student1.selectCourse(course2);
        student2.selectCourse(course2);
        student2.selectCourse(course3);
        student3.selectCourse(course1);
        student3.selectCourse(course3);

        // 按照年龄升序排列学生
        List<Student> sortedStudents = students.stream()
                .sorted((s1, s2) -> s1.getAge() - s2.getAge())
                .collect(Collectors.toList());
        System.out.println(sortedStudents);

        // 获取学生姓名列表
        List<String> studentNames = students.stream()
                .map(Student::getName)
                .collect(Collectors.toList());
        System.out.println(studentNames);

        // 获取学生所选的课程名列表
        List<String> studentCourseNames = students.stream()
                .flatMap(student -> student.getCourses().stream())
                .map(Course::getName)
                .collect(Collectors.toList());
        System.out.println(studentCourseNames);

        // 获取选择了"science"标签的课程
        List<Course> scienceCourses = courses.stream()
                .filter(course -> course.getLabel().equals("science"))
                .collect(Collectors.toList());
        System.out.println(scienceCourses);

        // 根据老师的年龄分组学生
        Map<Teacher, List<Student>> studentsByTeacher = students.stream()
                .collect(Collectors.groupingBy(Student::getTeacher));
        System.out.println(studentsByTeacher);
    }
}

class Student {
    public Teacher teacher;
    private String name;
    private int age;
    private List<Course> courses;

    public Student(String name, int age) {
        this.name = name;
        this.age = age;
        this.courses = new ArrayList<>();
    }

    public String getName() {
        return name;
    }

    public int getAge() {
        return age;
    }

    public List<Course> getCourses() {
        return courses;
    }

    public Teacher getTeacher() {
        return teacher;
    }

    public void selectCourse(Course course) {
        courses.add(course);
        course.addStudent(this);
    }

    @Override
    public String toString() {
        return "Student{" +
                "name='" + name + '\'' +
                ", age=" + age +
                '}';
    }
}

class Teacher {
    private String name;
    private int age;

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

    public String getName() {
        return name;
    }

    public int getAge() {
        return age;
    }

    @Override
    public String toString() {
        return "Teacher{" +
                "name='" + name + '\'' +
                ", age=" + age +
                '}';
    }
}

class Course {
    private String name;
    private String label;
    private List<Student> students;

    public Course(String name, String label) {
        this.name = name;
        this.label = label;
        this.students = new ArrayList<>();
    }

    public String getName() {
        return name;
    }

    public String getLabel() {
        return label;
    }

    public List<Student> getStudents() {
        return students;
    }

    public void addStudent(Student student) {
        students.add(student);
        student.teacher = student.getTeacher();
    }

    @Override
    public String toString() {
        return "Course{" +
                "name='" + name + '\'' +
                ", label='" + label + '\'' +
                '}';
    }
}

这段代码演示了如何使用Stream对包含学生、老师和课程的复杂数据进行处理。它展示了在使用Stream时常见的一些操作,如排序、映射、过滤、分组等。根据实际需求,你可以在此基础上进一步扩展和优化数据操作。

3、公司部门用户和商品订单,及一些常见的数据操作

import java.util.*;
import java.util.stream.Collectors;
public class Stream {
    public static void main(String[] args) {
        List<User> users = Arrays.asList(
                new User("John", "Company A", "Department A"),
                new User("Tom", "Company B", "Department B"),
                new User("Alice", "Company A", "Department B")
        );

        List<Order> orders = Arrays.asList(
                new Order("Product A", 5),
                new Order("Product B", 3),
                new Order("Product A", 2)
        );

        // 1. 根据公司分组用户
        Map<String, List<User>> usersByCompany = users.stream()
                .collect(Collectors.groupingBy(User::getCompany));
        System.out.println("Users grouped by company: " + usersByCompany);

        // 2. 过滤用户,只保留来自公司 A 的用户
        List<User> usersFromCompanyA = users.stream()
                .filter(u -> u.getCompany().equals("Company A"))
                .collect(Collectors.toList());
        System.out.println("Users from Company A: " + usersFromCompanyA);

        // 3. 获取部门为 Department B 的用户数量
        long departmentBUserCount = users.stream()
                .filter(u -> u.getDepartment().equals("Department B"))
                .count();
        System.out.println("Department B user count: " + departmentBUserCount);

        // 4. 获取每个用户的订单总数
        Map<User, Integer> orderCountByUser = users.stream()
                .collect(Collectors.toMap(
                        u -> u,
                        u -> orders.stream()
                                .filter(o -> o.getProduct().equals("Product A"))
                                .mapToInt(Order::getQuantity)
                                .sum()
                ));
        System.out.println("Order count by user: " + orderCountByUser);

        // 5. 获取所有订单的总数量
        int totalOrderCount = orders.stream()
                .mapToInt(Order::getQuantity)
                .sum();
        System.out.println("Total order count: " + totalOrderCount);
    }

}

class User {
    private String name;
    private String company;
    private String department;

    public User(String name, String company, String department) {
        this.name = name;
        this.company = company;
        this.department = department;
    }

    public String getName() {
        return name;
    }

    public String getCompany() {
        return company;
    }

    public String getDepartment() {
        return department;
    }
}

class Order {
    private String product;
    private int quantity;

    public Order(String product, int quantity) {
        this.product = product;
        this.quantity = quantity;
    }

    public String getProduct() {
        return product;
    }

    public int getQuantity() {
        return quantity;
    }
}

这个示例代码展示了使用 JDK 8 Stream API 进行一些常见的数据处理操作,包括分组、过滤、计数和求和等操作。你可以根据实际的复杂数据结构和需求来进行相应的修改和扩展。

  4、公司部门用户和商品订单,n个示例
    过滤过程:
    假设有一个用户列表List<User> users,过滤出年龄大于18岁的用户:

    List<User> filteredUsers = users.stream()
            .filter(user -> user.getAge() > 18)
            .collect(Collectors.toList());
    映射过程:
    假设有一个用户列表List<User> users,提取所有用户的用户名:

    List<String> usernames = users.stream()
            .map(user -> user.getUsername())
            .collect(Collectors.toList());
    排序过程:
    假设有一个用户列表List<User> users,按照年龄从小到大排序:

    List<User> sortedUsers = users.stream()
            .sorted(Comparator.comparingInt(User::getAge))
            .collect(Collectors.toList());
    分组过程:
    假设有一个订单列表List<Order> orders,根据公司进行分组:

    Map<Company, List<Order>> ordersByCompany = orders.stream()
            .collect(Collectors.groupingBy(Order::getCompany));
    聚合操作:
    假设有一个订单列表List<Order> orders,计算所有订单的总金额:

    double totalAmount = orders.stream()
            .mapToDouble(Order::getAmount)
            .sum();
    扁平化处理:
    假设有一个公司列表List<Company> companies,获取所有公司的部门列表:

    List<Department> departments = companies.stream()
            .flatMap(company -> company.getDepartments().stream())
            .collect(Collectors.toList());
    匹配元素:
    假设有一个用户列表List<User> users,检查是否存在年龄大于等于30岁的用户:

    boolean anyMatch = users.stream()
            .anyMatch(user -> user.getAge() >= 30);
    查找元素:
    假设有一个用户列表List<User> users,查找年龄最大的用户:

    Optional<User> maxAgeUser = users.stream()
            .max(Comparator.comparingInt(User::getAge));
    限制结果集:
    假设有一个订单列表List<Order> orders,获取前5个订单:

    List<Order> limitedOrders = orders.stream()
            .limit(5)
            .collect(Collectors.toList());
    跳过元素:
    假设有一个商品列表List<Product> products,跳过前3个商品,获取剩下的商品:

    List<Product> skippedProducts = products.stream()
            .skip(3)
            .collect(Collectors.toList());
    去重处理:
    假设有一个整数列表List<Integer> numbers,去除重复的数字:

    List<Integer> distinctNumbers = numbers.stream()
            .distinct()
            .collect(Collectors.toList());
    并行处理:
    假设有一个订单列表List<Order> orders,使用并行流计算订单的总金额:

    double totalAmount = orders.parallelStream()
            .mapToDouble(Order::getAmount)
            .sum();
    使用reduce聚合操作:
    假设有一个订单列表List<Order> orders,计算所有订单的总金额,使用reduce操作:

    double totalAmount = orders.stream()
            .map(Order::getAmount)
            .reduce(0.0, Double::sum);
    使用findFirst查找第一个元素:
    假设有一个订单列表List<Order> orders,查找第一个购买商品为手机的订单:

    Optional<Order> firstMobileOrder = orders.stream()
            .filter(order -> order.getProduct().equals("手机"))
            .findFirst();
    对集合元素进行批量操作:
    假设有一个用户列表List<User> users,将所有用户的年龄加5并更新:

    List<User> updatedUsers = users.stream()
            .peek(user -> user.setAge(user.getAge() + 5))
            .collect(Collectors.toList());
    多级分组:
    假设有一个商品列表List<Product> products,按照公司和部门进行多级分组:

    Map<Company, Map<Department, List<Product>>> productsByCompanyAndDepartment = products.stream()
            .collect(Collectors.groupingBy(Product::getCompany,
                    Collectors.groupingBy(Product::getDepartment)));
    使用flatMap进行嵌套处理:
    假设有一个公司列表List<Company> companies,获取所有公司的所有部门的所有员工姓名:

    List<String> employeeNames = companies.stream()
            .flatMap(company -> company.getDepartments().stream())
            .flatMap(department -> department.getEmployees().stream())
            .map(Employee::getName)
            .collect(Collectors.toList());
    查找满足条件的任意元素:
    假设有一个商品列表List<Product> products,查找任意一件库存大于0的商品:

    Optional<Product> anyProduct = products.stream()
            .filter(product -> product.getStock() > 0)
            .findAny();
    统计元素个数:
    假设有一个用户列表List<User> users,统计用户的数量:

    long userCount = users.stream()
            .count();
    使用forEach进行迭代操作:
    假设有一个订单列表List<Order> orders,打印所有订单的信息:

            orders.stream()
            .

    forEach(System.out::println);

    并行处理处理大数据量:
    假设有一个非常大的用户列表List<User> users,使用并行流进行处理:

            users.parallelStream()
            .

    filter(user ->user.getAge()>18)
            .

    forEach(System.out::println);

    使用collect进行自定义的聚合操作:
    假设有一个商品列表List<Product> products,将所有商品的名称用逗号连接起来:

    String names = products.stream()
            .map(Product::getName)
            .collect(Collectors.joining(", "));
    使用Optional处理可能为空的值:
    假设有一个List<Optional<User>> userList,筛选出非空的用户列表:

    List<User> nonEmptyUserList = userList.stream()
            .filter(Optional::isPresent)
            .map(Optional::get)
            .collect(Collectors.toList());
    连接字符串:
    假设有一个商品列表List<Product> products,将所有商品的名称以逗号分隔连接成一个字符串:

    String joinedNames = products.stream()
            .map(Product::getName)
            .collect(Collectors.joining(", "));
    对元素进行分页处理:
    假设有一个订单列表List<Order> orders,将订单按照每页10个进行分页:

    int pageSize = 10;
    int totalPages = (int) Math.ceil((double) orders.size() / pageSize);

    List<List<Order>> paginatedOrders = IntStream.range(0, totalPages)
            .mapToObj(page -> orders.stream()
                    .skip(page * pageSize)
                    .limit(pageSize)
                    .collect(Collectors.toList()))
            .collect(Collectors.toList());
    使用IntStream进行数值操作:
    假设有一个整数列表List<Integer> numbers,计算列表中所有偶数的平方和:

    int sumOfEvenSquares = numbers.stream()
            .filter(number -> number % 2 == 0)
            .mapToInt(number -> number * number)
            .sum();
    使用maxmin获取最大值和最小值:
    假设有一个整数列表List<Integer> numbers,找到列表中的最大值和最小值:

    Optional<Integer> maxNumber = numbers.stream()
            .max(Integer::compareTo);

    Optional<Integer> minNumber = numbers.stream()
            .min(Integer::compareTo);
    使用toMap将集合转换为Map
    假设有一个用户列表List<User> users,将用户按照ID作为键转换为Map

    Map<Integer, User> userMap = users.stream()
            .collect(Collectors.toMap(User::getId, Function.identity()));
    使用anyMatchallMatch进行条件判断:
    假设有一个用户列表List<User> users,检查是否所有用户的年龄都大于18岁:

    boolean allAdults = users.stream()
            .allMatch(user -> user.getAge() > 18);

    boolean anyAdult = users.stream()
            .anyMatch(user -> user.getAge() > 18);
    使用distinctsorted进行去重和排序:
    假设有一个整数列表List<Integer> numbers,去除重复值并对值进行排序:

    List<Integer> distinctSortedNumbers = numbers.stream()
            .distinct()
            .sorted()
            .collect(Collectors.toList());
    使用flatMap将多个列表合并为一个列表:
    假设有一个公司列表List<Company> companies,将每个公司的部门列表合并成一个部门列表:

    List<Department> allDepartments = companies.stream()
            .flatMap(company -> company.getDepartments().stream())
            .collect(Collectors.toList());
    使用reduce进行自定义聚合操作:
    假设有一个订单列表List<Order> orders,计算所有订单的总金额:

    double totalAmount = orders.stream()
            .map(Order::getAmount)
            .reduce(0.0, Double::sum);
    使用partitioningBy进行分区操作:
    假设有一个商品列表List<Product> products,按照库存是否大于0进行分区:

    Map<Boolean, List<Product>> partitionedProducts = products.stream()
            .collect(Collectors.partitioningBy(product -> product.getStock() > 0));
    使用zip操作将两个流合并为一个流:
    假设有一个用户列表List<User> users和一个商品列表List<Product>products,将两个列表合并为一个交替的流:

    Stream<Object> interleavedStream = StreamUtils.zip(users.stream(), products.stream());
    使用iterate生成一个无限流:
    假设需要生成一个自增的整数序列:

    Stream<Integer> sequentialNumberStream = Stream.iterate(0, i -> i + 1);
    使用toList将流转换为列表:
    假设有一个用户流Stream<User> userStream,将其转换为用户列表:

    List<User> userList = userStream.collect(Collectors.toList());
    使用toSet将流转换为集合:
    假设有一个商品流Stream<Product> productStream,将其转换为商品集合:

    Set<Product> productSet = productStream.collect(Collectors.toSet());
    使用joining将流转换为字符串:
    假设有一个部门流Stream<Department> departmentStream,将其转换为部门名称的逗号分隔字符串:

    String departmentNames = departmentStream.map(Department::getName)
            .collect(Collectors.joining(", "));
    使用summarizingInt计算流中的统计数据:
    假设有一个订单流Stream<Order> orderStream,计算订单金额的统计数据:

    DoubleSummaryStatistics orderStatistics = orderStream
            .collect(Collectors.summarizingDouble(Order::getAmount));
System.out.println("Total Orders: "+orderStatistics.getCount());
System.out.println("Total Amount: "+orderStatistics.getSum());
System.out.println("Average Amount: "+orderStatistics.getAverage());
System.out.println("Max Amount: "+orderStatistics.getMax());
System.out.println("Min Amount: "+orderStatistics.getMin());
    使用toMap将流转换为自定义的Map
    假设有一个用户流Stream<User> userStream,将其转换为以ID为键、用户对象为值的Map

    Map<Integer, User> userMap = userStream.collect(Collectors.toMap(User::getId, Function.identity()));
    使用groupingByConcurrent进行并发分组操作:
    假设有一个订单列表List<Order> orders,按照公司进行并发分组:

    ConcurrentMap<Company, List<Order>> ordersByCompany = orders.stream()
            .collect(Collectors.groupingByConcurrent(Order::getCompany));
    使用flatMapToInt计算流中元素的数值总和:
    假设有一个整数列表List<Integer> numbers,计算列表中所有元素的数值总和:

    int sum = numbers.stream()
            .flatMapToInt(IntStream::of)
            .sum();
    使用peek进行调试操作:
    假设有一个商品列表List<Product> products,在对每个商品进行其他操作之前,在控制台打印商品信息:

    List<Product> modifiedProducts = products.stream()
            .peek(product -> System.out.println("Processing product: " + product.getName()))
            .map(product -> /* 进行其他操作 */)
            .collect(Collectors.toList());
    五、
    常用总结
            根据mapkey进行排序
    升序排列
    Map<LocalDateTime, List<ExerciseReport>> twelveReportMap = twelveReportDataList.stream()
            .collect(Collectors.groupingBy(ExerciseReport::getCreateDate));
        System.out.println("twelveReportMap"+twelveReportMap);
    //根据时间进行升序排序
    Map<LocalDateTime, List<ExerciseReport>> result = new LinkedHashMap<>();
        twelveReportMap.entrySet().

    stream().

    sorted(Map.Entry.comparingByKey()).

    forEachOrdered(x ->result.put(x.getKey(),x.getValue()));
    降序排列
    Map<LocalDateTime, List<ExerciseReport>> twelveReportMap = twelveReportDataList.stream()
            .collect(Collectors.groupingBy(ExerciseReport::getCreateDate));
    //根据时间进行升序排序
    Map<LocalDateTime, List<ExerciseReport>> result = new LinkedHashMap<>();
        twelveReportMap.entrySet().

    stream().

    sorted(Collections.reverseOrder(Map.Entry.comparingByKey())).

    forEachOrdered(x ->result.put(x.getKey(),x.getValue()));
    String[] idStr转化为
    List<Long> ids
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;

    public class Main {
        public static void main(String[] args) {
            String[] idStr = {"1", "2", "3", "4", "5"};

            List<Long> ids = Arrays.stream(idStr)
                    .map(Long::parseLong)
                    .collect(Collectors.toList());

            System.out.println(ids);
        }
    }

       感谢大家的阅读,觉得有用的朋友可以收藏点赞,有问题的朋友可以留下你的问题一起交流讨论。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/314364.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Docker深入探索:网络与资源控制、数据管理与容器互联以及镜像生成

目录 一、 Docker网络 &#xff08;一&#xff09;Docker网络实现原理 &#xff08;二&#xff09;Docker网络模式 1. Bridge网络&#xff08;默认&#xff09; 2. Host网络 3. None网络 4. Container网络 5. 自定义网络 二、资源控制 &#xff08;一&#xff09;cgr…

从递归角度串联二叉树-图论-动态规划

一、深度理解二叉树的前中后序遍历 二叉树遍历框架如下&#xff1a; void traverse(TreeNode* root) {if (root nullptr) {return;}// 前序位置traverse(root->left);// 中序位置traverse(root->right);// 后序位置 }先不管所谓前中后序&#xff0c;单看 traverse 函数…

分布式与一致性协议之CAP(五)

CAP 理论 如何使用BASE理论 以InfluxDB系统中DATA节点的集群实现为例。DATA节点的核心功能是读和写&#xff0c;所以基本可用是指读和写的基本可用。我们可以通过分片和多副本实现读和写的基本可用。也就是说&#xff0c;将同一业务的数据先分片&#xff0c;再以多份副本的形…

Rust中的函数指针

什么是函数指针 通过函数指针允许我们使用函数作为另一个函数的参数。函数的类型是 fn &#xff08;使用小写的 ”f” &#xff09;以免与 Fn 闭包 trait 相混淆。fn 被称为 函数指针&#xff08;function pointer&#xff09;。指定参数为函数指针的语法类似于闭包。 函数指…

如何在TestNG中忽略测试用例

在这篇文章中&#xff0c;我们将讨论如何在TestNG中忽略测试用例。TestNG帮助我们忽略使用Test注释的情况&#xff0c;我们可以在不同的级别上忽略这些情况。 首先&#xff0c;只忽略一个测试方法或测试用例。第二&#xff0c;忽略一个类及其子类中的所有情况。第三个是&#…

【深度学习】YOLOv5,烟雾和火焰,目标检测,防火检测,森林火焰检测

文章目录 数据收集和数据标注查看标注好的数据的脚本下载yolov5创建 dataset.yaml训练参数开始训练yolov5n训练训练后的权重下载gradio部署 数据收集和数据标注 搜集数据集2w张。 pip install labelme labelme 然后标注矩形框和类别。 下载数据请看这里&#xff1a; https:…

图像处理之Retinex算法(C++)

图像处理之Retinex算法&#xff08;C&#xff09; 文章目录 图像处理之Retinex算法&#xff08;C&#xff09;前言一、单尺度Retinex&#xff08;SSR&#xff09;1.原理2.代码实现3.结果展示 二、多尺度Retinex&#xff08;MSR&#xff09;1.原理2.代码实现3.结果展示 三、带色…

【01-机器学习入门:理解Scikit-learn与Python的关系】

文章目录 前言Python与机器学习Scikit-learn简介Scikit-learn与Python的关系使用Scikit-learn进行机器学习结语 前言 在当今的数据科学和人工智能领域&#xff0c;机器学习已经成为了一个不可或缺的组成部分。而对于那些刚刚踏入这一领域的新手来说&#xff0c;理解机器学习的基…

线性代数 --- 矩阵的对角化以及矩阵的n次幂

矩阵的对角化以及矩阵的n次幂 &#xff08;特征向量与特征值的应用&#xff09; 前言&#xff1a; 在上一篇文章中&#xff0c;我记录了学习矩阵的特征向量和特征值的学习笔记&#xff0c;所关注的是那些矩阵A作用于向量x后&#xff0c;方向不发生改变的x(仅有尺度的缩放)。线…

Xilinx 7系列中clock IP核通过AXI4-Lite接口实现动态重新配置

当选择了动态重配置&#xff08;Dynamic Reconfiguration&#xff09;选项时&#xff0c;AXI4-Lite接口将默认被选中用于重新配置时钟组件。动态重新配置可以通过AXI4-Lite接口实现了Clocking Wizard IP核的时钟组件MMCM/PLL的动态重新配置。 如果需要直接访问MMCM/PLL的DRP寄…

C++ 头文件/宏冲突问题解决?如何解决?

&#x1f3c6;本文收录于「Bug调优」专栏&#xff0c;主要记录项目实战过程中的Bug之前因后果及提供真实有效的解决方案&#xff0c;希望能够助你一臂之力&#xff0c;帮你早日登顶实现财富自由&#x1f680;&#xff1b;同时&#xff0c;欢迎大家关注&&收藏&&…

SpringBoot + kotlin 协程小记

前言&#xff1a; Kotlin 协程是基于 Coroutine 实现的&#xff0c;其设计目的是简化异步编程。协程提供了一种方式&#xff0c;可以在一个线程上写起来像是在多个线程中执行。 协程的基本概念&#xff1a; 协程是轻量级的&#xff0c;不会创建新的线程。 协程会挂起当前的协…

【软件】ERETCAD-Env:在轨空间环境3D动态仿真软件

文章介绍了Extreme-environment Radiation Effect Technology Computer-Aided Design – Environment (ERETCAD-Env)软件&#xff0c;文章的介绍和展示了ERETCAD-Env软件的功能和特点&#xff0c;这是一款用于动态模拟在轨卫星所处空间环境的计算机辅助设计软件。强调了该软件在…

如何在CentOS本地搭建DataEase数据分析服务并实现远程查看数据分析

文章目录 前言1. 安装DataEase2. 本地访问测试3. 安装 cpolar内网穿透软件4. 配置DataEase公网访问地址5. 公网远程访问Data Ease6. 固定Data Ease公网地址 前言 DataEase 是开源的数据可视化分析工具&#xff0c;帮助用户快速分析数据并洞察业务趋势&#xff0c;从而实现业务…

pycharm远程连接server

1.工具–部署–配置 2.部署完成后&#xff0c;将现有的项目的解释器设置为ssh 解释器。实现在远端开发 解释器可以使用/usr/bin/python3

怎么排查K8S容器当中的Java程序内存泄露问题

今天早上发现生产线其中的一个服务在凌晨的时候突然重启了&#xff0c;内存突然从1G升到1.8G&#xff0c;CPU使用量从0.1升到了0.28&#xff0c;说明在这个时间点&#xff0c;内存突增达到了限额以上&#xff0c;服务重启了。因为这个服务布署了多节点&#xff0c;这次重启对业…

12 c++版本的坦克大战

前言 呵呵 这大概是 大学里面的 c 贪吃蛇了吧 有一些 面向对象的理解, 但是不多 这里 具体的实现 就不赘述, 仅仅是 发一下代码 以及 具体的使用 坦克大战 #include<iostream> #include<windows.h> #include<conio.h> #include<ctime> #include…

jvm(JVM快速入门、stack栈、堆、GC垃圾回收、Arthas)

文章目录 1. JVM快速入门1.1. 结构图1.2. 类加载器ClassLoader1.3. 执行引擎Execution Engine1.4. 本地接口Native Interface1.5. Native Method Stack1.6. PC寄存器(程序计数器)1.7. Method Area方法区 2. stack栈3. 堆3.1. 堆体系概述3.1.1. 新生区3.1.2. 老年代3.1.3. 永久代…

分类预测 | Matlab实现CNN-GRU-SAM-Attention卷积门控循环单元融合空间注意力机制的数据分类预测

分类预测 | Matlab实现CNN-GRU-SAM-Attention卷积门控循环单元融合空间注意力机制的数据分类预测 目录 分类预测 | Matlab实现CNN-GRU-SAM-Attention卷积门控循环单元融合空间注意力机制的数据分类预测分类效果基本描述程序设计参考资料 分类效果 基本描述 1.Matlab实现CNN-GRU…

Visual Studio 对 C++ 头文件和模块的支持

在 C 编程领域&#xff0c;头文件和模块的管理有时候确实比较令人头疼。但是&#xff0c;有许多工具和功能可以简化此过程&#xff0c;提高效率并减少出错的可能性。下面是我们为 C 头文件和模块提供的几种工具的介绍。 构建明细 通过菜单栏 Build > Run Build Insights&a…