Java:Lambda表达式、Stream

简介: Java:Lambda表达式、Stream

函数式接口 @FunctionalInterface

package com.demo;
import java.util.Arrays;
import java.util.Comparator;
public class Demo {
    public static void main(String[] args) {
        String[] array = new String[]{"pig", "cat", "dog"};
        Arrays.sort(array, new Comparator<String>(){
            @Override
            public int compare(String s1, String  s2) {
                return s1.compareTo(s2);
            }
        });
        System.out.println(Arrays.toString(array));
        // [cat, dog, pig]
    }
}

Lambda表达式

package com.demo;
import java.util.Arrays;
public class Demo {
    public static void main(String[] args) {
        String[] array = new String[]{"pig", "cat", "dog"};
        Arrays.sort(array, (s1, s2) -> {
            return s1.compareTo(s2);
        });
        System.out.println(Arrays.toString(array));
        // [cat, dog, pig]
    }
}

引用静态方法

package com.demo;
import java.util.Arrays;
public class Demo {
    public static void main(String[] args) {
        String[] array = new String[]{"pig", "cat", "dog"};
        Arrays.sort(array, Demo::compareTo);
        System.out.println(Arrays.toString(array));
        // [cat, dog, pig]
    }
    public static int compareTo(String s1, String s2){
        return s1.compareTo(s2);
    }
}

引用实例方法

// public int compareTo(String anotherString)
// 相当于:
// public static int compareTo(String this, String anotherString)
Arrays.sort(array, String::compareTo);

引用构造方法

class Person {
    private String name;
    public Person(String name) {
        this.name = name;
    }
}
package com.demo;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
public class Demo {
    public static void main(String[] args) {
        List<String> names = Arrays.asList("Tom", "Jack", "Steve");
        List<Person> persons = new ArrayList<>();
        for (String name : names) {
            persons.add(new Person(name));
        }
    }
}

简写

package com.demo;
import java.util.Arrays;
import java.util.List;
import java.util.stream.Collectors;
public class Demo {
    public static void main(String[] args) {
        List<String> names = Arrays.asList("Tom", "Jack", "Steve");
        List<Person> persons = names.stream()
                .map(Person::new)
                .collect(Collectors.toList());
    }
}

创建Stream

String[] pets = new String[]{"pig", "dog", "cat"};
Stream<String> stream = Arrays.stream(pets);
Stream<String> stream = Stream.of("pig", "dog", "cat");
Stream<String> stream = Arrays.asList("pig", "dog", "cat").stream();
// 映射
Stream<Integer> stream = Stream.of(1, 2, 3);
stream.map(x -> x * x).forEach(System.out::println);
// 1 4 9
// 过滤,留下偶数
Stream<Integer> stream = Stream.of(1, 2, 3);
stream.filter(x -> x % 2 == 0).forEach(System.out::println);
// 2
// 聚合
Stream<Integer> stream = Stream.of(1, 2, 3);
int ret  = stream.reduce(0, (sum, x) -> sum + x);
System.out.println(ret);
// 2

Stream提供的常用操作有:


转换操作:map(),filter(),sorted(),distinct();


合并操作:concat(),flatMap();


并行处理:parallel();


聚合操作:reduce(),collect(),count(),max(),min(),sum(),average();


其他操作:allMatch(), anyMatch(), forEach()。


目录
打赏
0
0
0
0
83
分享
相关文章
SpringBoot整合Flowable【06】- 查询历史数据
本文介绍了Flowable工作流引擎中历史数据的查询与管理。首先回顾了流程变量的应用场景及其局限性,引出表单在灵活定制流程中的重要性。接着详细讲解了如何通过Flowable的历史服务API查询用户的历史绩效数据,包括启动流程、执行任务和查询历史记录的具体步骤,并展示了如何将查询结果封装为更易理解的对象返回。最后总结了Flowable提供的丰富API及其灵活性,为后续学习驳回功能做了铺垫。
314 0
SpringBoot整合Flowable【06】- 查询历史数据
【回顾 · 向新】一图看懂阿里云存储 2024 年终回顾
云存储2024商业市场、产品能力升级、解决方案升级以及客户墙
Python和阿里云AI服务搭建
使用Python和阿里云AI服务搭建一个简单的聊天机器人的教程 1. 注册阿里云账号并登录。 2. 开通阿里云AI服务,并创建一个智能对话机器人。 3. 获取API密钥和AccessToken。 4. 安装Python环境和SDK。
454 8
若依修改定时任务,定时任务在系统监控的定时任务当中,宕机情况都不会去管,涉及到定时任务
若依修改定时任务,定时任务在系统监控的定时任务当中,宕机情况都不会去管,涉及到定时任务
海量非结构化数据存储中的小对象合并技术
随着人工智能, IoT 等技术的推广普及,智能监控,智能制造等新兴领域蓬勃发展,涌现出了越来越多的海量非结构化数据存储需求。
【SpringBoot学习笔记 八】SpringBoot定制整合SpringMVC
【SpringBoot学习笔记 八】SpringBoot定制整合SpringMVC
238 0
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等

登录插画

登录以查看您的控制台资源

管理云资源
状态一览
快捷访问