java8 : 流

package day02.com.offcn.test;

import java.io.IOException;
import java.nio.charset.Charset;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.*;
import java.util.stream.*;

/**
 * @author: CC
 * @date: 2019/9/8
 */
public class 流 {
    //流的创建
    public static void main(String[] args) throws IOException {
        //由值创建流,静态方法Stream.of
        Stream<String> stream = Stream.of("JAVA 8","Lambdas","In","Action");

        //由数组创建流, 静态方法Arrays.stream
        int[] numbers = {3,4,5,6,11,13};
        int sum = Arrays.stream(numbers).sum();

        //由文件生成流
        Stream<String> lines = Files.lines(Paths.get("D:/aa.txt"), Charset.defaultCharset());
        long sum1 = lines.count();

        //由函数生成流,生成无限流
        //迭代
        Stream.iterate(0,n->n+2)
                .limit(10)
                .forEach(System.out::println);
        //生成
        Stream.generate(Math::random)
                .map(aDouble -> aDouble*100)
                .limit(10)
                .forEach(System.out::print);

        //collection构建流,集合流
        Collection collection = new HashSet();
        collection.stream();

//        中间操作（intermediate）主要有以下方法（此类型的方法返回的都是Stream对象）：
//        map (mapToInt, flatMap 等)、 filter、 distinct、 sorted、 peek、
//        limit、 skip、 parallel、 sequential、 unordered

        List<String> list = Arrays.asList("aaa","ddd","bbb","ccc","a2a","d2d","b2b","c2c","a3a","d3d","b3b","c3c");

        List list1 = list.stream()
                .filter(s -> s.equals("aaa"))
                .map(s -> "df")
                .distinct()
                .limit(10)
                .skip(5)
                .mapToInt(value -> 10)
                .mapToDouble(value -> 0.1)
                .mapToLong(value -> 23)
                .mapToObj(value -> "dsfs")
                .sorted()
                .parallel()
                .peek(System.out::print)
                .collect(Collectors.toList());
        //留意装箱。自动装箱和拆箱操作会大大降低性能。Java 8中有原始类型流（IntStream、
        //LongStream、DoubleStream）来避免这种操作，但凡有可能都应该用这些流。
        
        Object[] obj = list1.stream().toArray();
        Arrays.asList(obj).stream().max((o1, o2) -> 0);
        Arrays.asList(obj).stream().min((o1, o2) -> 0);
        boolean boo = Arrays.asList(obj).stream().allMatch(o -> true);
        Arrays.asList(obj).stream().forEach(System.out::print);
        Arrays.asList(obj).stream().count();
        Arrays.asList(obj).stream().iterator();
//        终端操作（terminal）主要有以下方法：
//        forEach、 forEachOrdered、 toArray、 reduce、 collect、
//        min、 max、 count、 anyMatch、 allMatch、 noneMatch、
//        findFirst、 findAny、 iterator
    }
}