jdk1.8 stream特性

最近换工作了，用到了Stream，今天无事好好研究一下。

1 filter方法 返回值stream  参数为一个方法，返回true或者false 过滤数据为false的。

2 foreach 方法  返回值void 参数方法 单个item ，没有返回值，和for循环类似，效率没有for高。

3 map方法  返回值stream  参数方法  参数item 返回值类型自己定义  修改了stream的类型  

4 collect方法 返回一个集合  一般可用Collectors中的to方法作为其参数。

5 flatmap方法 返回值 stream 方法参数为一个T参数的返回stream的方法 即  Stream function（T）

例子：

 

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
import java.util.stream.Stream;

public class Test {

    public static void main(String[] args) {
        List<CommonBean> arr=new ArrayList<>();
        for(int i=0;i<10000;i++){
            CommonBean commonBean=new CommonBean();
            commonBean.setAddress("address"+i);
            commonBean.setName("name"+i);
            commonBean.setProt(i);
            commonBean.setUser("user"+i);
            arr.add(commonBean);
        }
        List<CommonBean> arr2=new ArrayList<>();
        for(int i=0;i<10000;i++){
            CommonBean commonBean=new CommonBean();
            commonBean.setAddress("address1"+i);
            commonBean.setName("name1"+i);
            commonBean.setProt(i+1);
            commonBean.setUser("user"+i);
            arr2.add(commonBean);
        }
//        List<CommonBean> collect = arr.stream().skip(2).collect(Collectors.toList());
//        List<CommonBean> collect =
//            arr.stream().filter(commonBean ->commonBean.getProt()==3 ).collect(Collectors.toList());
        //forEach方法
//        arr.stream().forEach(commonBean ->{commonBean.setProt(1);} );
        //map方法从一个commonBean流变成一个Integer流
//        List<Integer> collect = arr.stream().map(commonBean -> {
//            return commonBean.getProt();
//        }).filter(aa->aa>4).collect(Collectors.toList());
        List<Integer> collect =
            arr.stream().map(CommonBean ::getProt).filter(aa->aa>4).sorted((o1,o2)->{return 0;}).collect(Collectors.toList());
        //线程安全的集合
        //List<Integer> collect2=new Vector<>();
//        List<Integer> collect3=new CopyOnWriteArrayList<>(collect2);
//        Set<Integer> set = Collections.newSetFromMap(new ConcurrentHashMap<>());

//        Set<Integer> set = Collections.synchronizedSet(new HashSet<>()) ;
        //parallelStream 并发执行，注意使用线程安全的类
//        List<Integer> collect1 =
//            arr.parallelStream().map(commonBean ->{
//            collect2.add(commonBean.getProt());
//            set.add(commonBean.getProt());
//            return commonBean.getProt();}).collect(Collectors.toList());
        //collect方法 将list变成map  注意 Collectors.toMap中的参数a，b其实都是指stream<T>中的泛型T
//        Map<Integer,Integer> map=
//            arr.parallelStream().map(CommonBean::getProt).collect(Collectors.toMap(a->a,b->b));
        Map<Integer,Integer> map=
            Stream.of(arr2,arr).flatMap(arg->arg.parallelStream())
            .map(CommonBean ::getProt).collect(Collectors.toMap(a->a,
            b->b,( c, d)-> c>d?c:d));
        System.out.println(map.size());

    }

}

public class CommonBean {

    private String name;
    private String address;
    private Integer prot;
    private String user;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getAddress() {
        return address;
    }

    public void setAddress(String address) {
        this.address = address;
    }

    public Integer getProt() {
        return prot;
    }

    public void setProt(Integer prot) {
        this.prot = prot;
    }

    public String getUser() {
        return user;
    }

    public void setUser(String user) {
        this.user = user;
    }
}

更多内容请参考https://www.runoob.com/java/java8-streams.html