java8中的Stream常用方法有哪些-创新互联

这篇文章主要介绍了java8中的Stream常用方法有哪些，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。

Stream 常用方法

创建Stream

1. 将现有数据结构转化成Stream

Stream s = Stream.of(1, 2, 3, 4, 5);
Stream s = Arrays.stream(arr);
Stream s = aList.stream();

1. 通过Stream.generate()方法：

// 这种方法通常表示无限序列
Stream s = Stream.generate(SuppLier s);
// 创建全体自然数的Stream
class NatualSupplier implements Supplier {
    BigInteger next = BigInteger.ZERO;
    @Override
    public BigInteger get() {
        next = next.add(BigInteger.ONE);
        return next;
    }
}

1. 通过其他方法返回

Stream lines = Files.lines(Path.get(filename))
...

map方法

把一种操作运算映射到Stream的每一个元素上，从而完成一个Stream到另一个Stream的转换
map方法接受的对象是Function接口，这个接口是一个函数式接口：

 Stream map(Function mapper);


@FunctionalInterface
public interface Function {
    // 将T转换为R
    R apply(T t);
}

使用：

// 获取Stream里每个数的平方的集合
Stream ns = Stream.of(1, 2, 3, 4, 5);
ns.map(n -> n * n).forEach(System.out::println);

flatMap

map方法是一个一对一的映射，每输入一个数据也只会输出一个值。

flatMap方法是一对多的映射，对每一个元素映射出来的仍旧是一个Stream，然后会将这个子Stream的元素映射到父集合中：

Stream> inputStream = Stream.of(Arrays.asList(1), Arrays.asList(2, 3), Arrays.asList(4, 5, 6));
List integerList = inputStream.flatMap((childList) -> childList.stream()).collect(Collectors.toList());
//将一个“二维数组”flat为“一维数组”
integerList.forEach(System.out::println);

filter方法

filter方法用于过滤Stream中的元素，并用符合条件的元素生成一个新的Stream。
filter方法接受的参数是Predicate接口对象，这个接口是一个函数式接口：

Stream filter(Predicate) predicate;


@FunctionInterface
public interface Predicate   {
    // 判断元素是否符合条件
    boolean test(T t);
}

使用

// 获取当前Stream所有偶数的序列
Stream ns = Stream.of(1, 2, 3, 4, 5);
ns.filter(n -> n % 2 == 0).forEach(System.out::println);

limit、skip

limit用于限制获取多少个结果，与数据库中的limit作用类似，skip用于排除前多少个结果。

sorted

sorted函数需要传入一个实现Comparator函数式接口的对象，该接口的抽象方法compare接收两个参数并返回一个整型值，作用就是排序，与其他常见排序方法一致。

distinct

distinct用于剔除重复，与数据库中的distinct用法一致。

findFirst

findFirst方法总是返回第一个元素，如果没有则返回空，它的返回值类型是Optional类型，接触过swift的同学应该知道，这是一个可选类型，如果有第一个元素则Optional类型中保存的有值，如果没有第一个元素则该类型为空。

Stream stream = users.stream();
Optional userID = stream.filter(User::isVip).sorted((t1, t2) -> t2.getBalance() - t1.getBalance()).limit(3).map(User::getUserID).findFirst();
userID.ifPresent(uid -> System.out.println("Exists"));

min、max

min可以对整型流求最小值，返回OptionalInt。

max可以对整型流求大值，返回OptionalInt。

这两个方法是结束操作，只能调用一次。

allMatch、anyMatch、noneMatch

allMatch：Stream中全部元素符合传入的predicate返回 true

anyMatch：Stream中只要有一个元素符合传入的predicate返回 true

noneMatch：Stream中没有一个元素符合传入的predicate返回 true

reduce方法

reduce方法将一个Stream的每一个元素一次作用于BiFunction，并将结果合并。
reduce方法接受的方法是BinaryOperator接口对象。

Optional reduce(BinaryOperator accumulator);


@FuncationalInterface
public interface BinaryOperator extends BiFunction {
    // Bi操作，两个输入，一个输出
    T apply(T t, T u);
}

使用：

// 求当前Stream累乘的结果
Stream ns = Stream.of(1, 2, 3, 4, 5);
int r = ns.reduce( (x, y) -> x * y ).get();
System.out.println(r);

感谢你能够认真阅读完这篇文章，希望小编分享的“java8中的Stream常用方法有哪些”这篇文章对大家有帮助，同时也希望大家多多支持创新互联成都网站设计公司，关注创新互联成都网站设计公司行业资讯频道，更多相关知识等着你来学习!

另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、网站设计器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。