Java - Stream 流式计算

男娘i 2022-09-07 01:18 136阅读 0赞

## 四大函数式接口 ##

### Function ###

函数型接口：有入参，有返回值

public void testFunction() { 
        // JDK1.8之前的写法
        Function<String, String> f1 = new Function<String, String>() { 
            @Override
            public String apply(String s) { 
                return s;
            }
        };
        // 替换Lambda写法
        Function<String, String> f2 = (str) -> { return str;};
        // 精简写法
        Function<String, String> f3 = str -> str;
    
        System.out.println(f1.apply("hello"));
        System.out.println(f2.apply("hello"));
        System.out.println(f3.apply("hello"));
    }

### Predicate ###

断定型接口：有入参，返回布尔值。

public void testPredicate() { 
        Predicate<String> predicate = s -> s.contains("abc");
        System.out.println(predicate.test("helloabc"));
    }

### Consumer ###

消费型接口：有入参，没有返回值。

public void testConsumer() { 
        Consumer<String> consumer = s -> System.out.println(s);
        consumer.accept("hello");
    }

### Supplier ###

供给型接口：没有参数，只有返回值。

public void testSupplier() { 
        Supplier<String> supplier = () -> "hello";
        System.out.println(supplier.get());
    }

## Stream 流式计算 ##

一个案例搞清楚 Stream 的计算方式：

按以下条件筛选：

1、ID 为偶数

2、age>23

3、name转为大写字母

4、按用户名字母倒叙排列

5、只输出一个用户

public void streamCalcDemo() { 
        User user1 = new User(1, 18, "lisa");
        User user2 = new User(2, 19, "pika");
        User user3 = new User(3, 20, "sandy");
        User user4 = new User(4, 35, "alice");
        User user5 = new User(6, 24, "flask");
        List<User> list = Arrays.asList(user1, user2, user3, user4, user5);
    
        list.stream()
            .filter(u -> { return u.getId() % 2 == 0;})
            .filter(u -> { return u.getAge() > 23; })
            .map((u) -> { 
                u.setName(u.getName().toUpperCase(Locale.ROOT));
                return u;
            })
            // String 类中自带 compareTo() 方法
            // 不是很复杂的排序都不需要实现Comparator接口
            .sorted((u1,u2)->{ return u2.getName().compareTo(u2.getName());})
            .limit(1)
            .forEach(item->{ 
                System.out.println(item.toString());
            });
    }
    
    @Data
    @ToString
    @AllArgsConstructor
    class User { 
        private int id;
        private int age;
        private String name;
    }