Java Stream在Android上的应用

Java中的函数式编程

1. Stream是延迟操作的。Stream由0或多个中间操作符(Intermediate Operaions)和一个终态操作符(Terminal Operation)组成，只有当初始化终态操作符时，对数据源的操作才会触发。

2. Stream本身不存储数据。数据从数据源到终态操作符的传递都是通过管道(Stream Pipeline)进行。

3. Stream不改变数据源中的数据。例如使用filter对数据源筛选时，不会真的将不满足条件的数据从数据源中删去

4. Stream的数据只能被访问一次。比如数据源是一个int型数组[1,2,3], 当Stream遍历到2后，当前Stream便不被允许再次访问1，只能重新创建一个Stream，重新将数据源作为输入传递给新创建的Stream。

使用Java Stream简化代码

// 非Stream实现
public List<String> collect(List<User> users) {
    List<User> userList = new ArrayList<>();
    // 筛选出年龄大于等于 60 的用户
    for (User user : users)
        if (user.age >= 60)
            userList.add(user);

    // 将他们的年龄从大到小排序
    userList.sort(Comparator.comparing(User::getAge).reversed());
        
    List<String> result = new ArrayList<>();
    for (User user : userList)
        result.add(user.name);
    return result;
}

public List<String> collect(List<User> users) {
    return users.stream()
            .filter(user -> user.age >= 60)
            .sorted(comparing(User::getAge).reversed())
            .map(User::getName)
            .collect(Collectors.toList());
}

List<String> read(List<String> fileList) {
   return fileList.parallelStream()
       .map(this::getStringFromNet)
       .map(it -> {
            try {
                return it.get();
             // 这一段代码也可以写入到getStringFromNet中
            } catch (ExecutionException|InterruptedException e) {
                return null;
            }
        })
        .filter(Objects::nonNull)
        .collect(Collectors.toList());
    }

CompletableFuture<String> getStringFromNet(String file) {
    // 耗时操作
}

Android下使用Java Stream

中间操作符

<R> Stream<R> map(Function<? super T, ? extends R> mapper);

Stream<T> filter(Predicate<? super T> predicate);

<R> Stream<R> flatMap(Function<? super T, ? extends Stream<? extends R>> mapper);

终态操作符

T reduce(T identity, BinaryOperator<T> accumulator);

使用流需要注意几下几点：

1. 不要改变数据源本身，即不能再中间操作符中执行对数据源本身的更改，例如add，remove数据源数组

2. 在stream中不要操作管道外的数据。左下面的代码在并发流中是有问题的，我们完全可以通过改变stream的写法达到一样的效果，如右下。例子来自于

ArrayList<String> results 
      = new ArrayList<>();
stream.filter(s -> 
    pattern.matcher(s).matches())
  .forEach(s -> results.add(s));

List<String>results =
 stream.filter(s -> 
   pattern.matcher(s).matches())
    .collect(Collectors.toList());

使用并发流(Parallel Stream)

1. 多线程下，数据源中的分片规则是什么？这个规则需要保证每个子线程获取的数据不包含重复部分，又要注重效率。

2. 子线程执行完成后，如何保证结果能够正确的合并？

<R, A> R collect(Collector<? super T, A, R> collector);
public interface Collector<T, A, R> {
  Supplier<A> supplier();
  BiConsumer<A, T> accumulator();
  BinaryOperator<A> combiner();
  Function<A, R> finisher();
  Set<Characteristics> characteristics();
}

How does reduce() method work with parallel streams in Java 8?

Thanks for contributing an answer to Stack Overflow! Please be sure to answer the question. Provide details and share your research! Asking for help, clarification, or responding to other answers. Making statements based on opinion; back them up with references or personal experience. To learn more, see our tips on writing great answers.

https://stackoverflow.com/questions/56023452/how-does-reduce-method-work-with-parallel-streams-in-java-8

public class App {

    public static void main(String[] args) {
        String[] grades = {"A", "B", "C", "D", "E", "F", "G", "H", "I", "J", "K"};

        StringBuilder concat = Arrays.stream(grades).parallel()
                .reduce(new StringBuilder(),
                        (sb, s) -> sb.append(s),
                        (sb1, sb2) -> sb1.append(sb2));

        System.out.println(concat);

    }
}

StringBuilder concat = Arrays.stream(grades).parallel()
   .collect(StringBuilder::new, StringBuilder::append, StringBuilder::append);

Java如何支持函数式编程？-阿里云开发者社区

在很长的一段时间里，Java一直是面向对象的语言，一切皆对象，如果想要调用一个函数，函数必须属于一个类或对象，然后在使用类或对象进行调用。但是在其它的编程语言中，如JS、C++，我们可以直接写一个函数，然后在需要的时候进行调用，既可以说是面向对象编程，也可以说是函数式编程。从功能上来看，面向对象编程没什么不好的地方，但是从开发的角度来看，面向对象编程会多写很多可能是重复的代码行。比如创建一个...

https://developer.aliyun.com/article/772929

浅谈函数式编程与 Java Stream - 掘金

前言 在这一篇文章中，我将介绍函数式编程的基本概念，如何使用函数式编程的思想编写代码以及 Java Stream 的基本使用方法。 本文不会涉及到任何晦涩难懂的数学概念，函数式编程的理论以及函数式编程

https://juejin.cn/post/7009925824899973150#heading-11

Java Stream 详解

Stream是 Java 8新增加的类，用来补充集合类。 Stream代表数据流，流中的数据元素的数量可能是有限的，也可能是无限的。 Stream和其它集合类的区别在于：其它集合类主要关注与有限数量的数据的访问和有效管理(增删改)，而Stream并没有提供访问和管理元素的方式，而是通过声明数据源的方式，利用可计算的操作在数据源上执行，当然 BaseStream.iterator() 和 ...

https://colobu.com/2016/03/02/Java-Stream/