转载

一文了解：JDK8的Stream流操作以及lambda表达式

Lambda Jdk8

Lambda 是一个匿名函数，只关注参数列表和方法体,我们可以把 Lambda表达式理解为是一段可以传递的代码（将代码像数据一样进行传递)

类型推断:省略参数类型

与内部类比较

内部类this关键字指向内部类本身,Lambda中this指向lambda所处在的类

Java编译器将lambda表达式编译成类的私有方法。使用了Java 7的 invokedynamic 字节码指令来动态绑定这个方法。

表达式

引入了->新操作符:参数表加操作体

(Parameters)->{expressions}复制代码

方法引用

类名 :: 方法名

功能接口(使用要求)

使用@FunctionalInterface注解

接口中的抽象方法只能是一个(函数式接口)

Predicate

java.util.function.Predicate函数式接口,向API方法添加逻辑,非常适合做过滤器

List<String> names=Arrays.asList("dx","wdt","zfb","wuguangyao","nihaoshiw"));
        Predicate<String> filter1 = str->str.length()>5;
        Predicate<String> filter2 = str->str.endsWith("yao");
       // filter(names,(n)->((String)n).startsWith("d"));
        filter(names,filter2);
        names.stream().filter(filter1.and(filter2))
                .forEach(System.out::println);
    }

    public static void filter(List<String> list, Predicate condition){
        for(String str:list){
            if(condition.test(str)){
                System.out.println(str);
            }
        }
    }复制代码

Runnable

Runnable t = ()-> System.out.println("hello");
        t.run();复制代码

Collections

根接口

sort

implements Comparable

实体类实现Comparable接口

public class Student implements Comparable<Student> {
~~~~
@Override
    public int compareTo(Student o) {
        return stuId.compareTo(o.getStuId());
    }复制代码

Collections.sort(List,new Comparator())

创建一个比较器实现Comparator接口

Collections.sort(list, new Comparator<StudentNoSort>() {
            @Override
            public int compare(StudentNoSort o1, StudentNoSort o2) {
                return o1.getStuId().compareTo(o2.getStuId());
            }
        });复制代码

Stream

使用Jdk8 Stream更加简单

List<StudentNoSort> streamList = list.stream()
                .filter(w -> w.getClass()==StudentNoSort.class)
                .sorted(((o1, o2) -> o1.getStuId().compareTo(o2.getStuId())))
                .collect(Collectors.toList());复制代码

Stream

Stream 不是集合元素，它不是数据结构并不保存数据，它是有关算法和计算的，它更像一个高级版本的 Iterator。原始版本的 Iterator，用户只能显式地一个一个遍历元素并对其执行某些操作；高级版本的 Stream，用户只要给出需要对其包含的元素执行什么操作，比如 “过滤掉长度大于 10 的字符串”、“获取每个字符串的首字母”等，Stream 会隐式地在内部进行遍历，做出相应的数据转换。

Stream构成

获取一个数据源（source）→ 数据转换→执行操作(返回新的Stream对象)，这就允许对其操作可以像链条一样排列，变成一个管道

一文了解：JDK8的Stream流操作以及lambda表达式

Stream Source

集合，数组，I/O channel，产生器generator 等

Stream Operation

Intermediate

一个流可以后面跟随零个或多个 intermediate 操作。其目的主要是打开流，做出某种程度的数据映射/过滤，然后返回一个新的流，交给下一个操作使用。

collect

创建一个List

filter

过滤器:集合进行过滤操作

distinct

集合元素去重

map

对函数进行操作

reduce

组合元素

forEach

遍历元素

limit

限定流中数据的数量

sorted

排序使用Comparator接口

march,allMatch,noneMatch,anyMatch

符合元素传入predicate,返回boolean

还有以下

mapToInt (转换为int), summaryStatistics(int型变量统计) ,sum(int型求和)

Terminal

一个流只能有一个 terminal 操作，当这个操作执行后，流就被使用“光”了，无法再被操作。

构造Stream

Collections

Collections
List<String> list = Arrays.asList(strArray);
stream = list.stream();复制代码

example:

List<Integer> list = new ArrayList<>(Arrays.asList(1, 2, 12, 1, 1, 2, 3, 2, 432, 4, 32, 54, 3, 3));
        int sum = list.stream().map(x -> x * x)
                .reduce((x, y) -> x + y)
                .get();复制代码

遍历文件(nio+lambda)

Path start = FileSystems.getDefault().getPath("/home/dzou/报告/模电");
        Files.walk(start)
                .filter(path -> path.toFile().isFile())
                .filter(path -> path.toString().endsWith(".jpg"))
                .forEach(System.out::println);复制代码

时间复杂度

Stream 里有个操作函数的集合，每次转换操作就是把转换函数放入这个集合中，在 Terminal 操作的时候循环 Stream 对应的集合，然后对每个元素执行所有的函数

并行parallelStream

我们看这个代码,输出不是顺序的

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9);
        numbers.parallelStream()
                .forEach(out::println);复制代码

底层使用ForkJoinPool,相比于ThreadPoolExecutor,可以让线程创建新的任务,并挂起当前任务,此时线程可以在队列中选择子任务执行

原文 https://juejin.im/post/5dce35dbf265da0bdd450ae8

正文到此结束

所属分类： Java 编程技术

本文标签： rmi 线程时间 dist Collection tar 代码 example IO API ThreadPoolExecutor NIO https IDE 参数 executor stream mina 数据 list ACE lambda db UI Collections http 字节码编译 map 遍历统计 ArrayList java cat CTO src id
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

其他链接

关于本站

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。

问题交流

一文了解：JDK8的Stream流操作以及lambda表达式

Lambda Jdk8

与内部类比较

表达式

方法引用

功能接口(使用要求)

Predicate

Runnable

Collections

sort

implements Comparable

Collections.sort(List,new Comparator())

Stream

Stream

Stream构成

Stream Source

Stream Operation

Intermediate

collect

filter

distinct

map

reduce

forEach

limit

sorted

march,allMatch,noneMatch,anyMatch

还有以下

Terminal

构造Stream

example:

遍历文件(nio+lambda)

时间复杂度

并行parallelStream

热门推荐

相关文章

说给你听

本文目录

随机标签

书籍教程

近期评论

网站信息

其他链接

关于本站

问题交流