stream流操作List工具类

╰半夏微凉° 2021-12-11 22:21 327阅读 0赞

工作中操作List对于程序猿来说是"基本操作",为了更加便利,对JDK8的新特性stream流进行二次封装.话不多说,直接上代码

package com.mydemo;
    
    import org.apache.commons.collections.CollectionUtils;
    import java.util.Comparator;
    import java.util.List;
    import java.util.function.Function;
    import java.util.function.Predicate;
    import java.util.stream.Collectors;
    
    /**
     * JDK8 stream流操作工具类
     * @author Jozz
     */
    public class StreamUtils {
    
        /**
         * 映射
         * @param data 不能为空
         * @param fun
         * @param <T>
         * @param <R>
         * @return data为空抛出异常IllegalArgumentException
         */
        public static <T,R> List<R> map(List<T> data, Function<T,R> fun){
            if (CollectionUtils.isEmpty(data)){
                throw new IllegalArgumentException();
            }
            return data.stream().map(fun).collect(Collectors.toList());
        }
    
        /**
         * 过滤
         * @param data
         * @param pre
         * @param <T>
         * @return data为空返回data
         */
        public static <T> List<T> filter(List<T> data, Predicate<T> pre){
            if (CollectionUtils.isEmpty(data)){
                return data;
            }
            return data.stream().filter(pre).collect(Collectors.toList());
        }
    
        /**
         * 排序
         * @param data
         * @param comparator
         * @param <T>
         * @return data为空返回data
         */
        public static <T> List<T> sorted(List<T> data, Comparator<T> comparator){
            if (CollectionUtils.isEmpty(data)){
                return data;
            }
            return data.stream().sorted(comparator).collect(Collectors.toList());
        }
    
        /**
         * 去重
         * @param data
         * @param <T>
         * @return data为空返回data
         */
        public static <T> List<T> distinct(List<T> data){
            if (CollectionUtils.isEmpty(data)){
                return data;
            }
            return data.stream().distinct().collect(Collectors.toList());
        }
    
        /**
         * 判断是否包含匹配元素
         * @param data
         * @param pre
         * @param <T>
         * @return data为空返回false
         */
        public static <T> boolean anyMatch(List<T> data, Predicate<T> pre){
            if (CollectionUtils.isEmpty(data)){
                return false;
            }
            return data.parallelStream().anyMatch(pre);
        }
    
        /**
         * 将list进行join操作
         * @param data
         * @param join
         * @return 返回join之后的字符串,data为空返回null
         */
        public static String join(List<String> data,String join){
            if (CollectionUtils.isEmpty(data)){
                return null;
            }
            return data.stream().collect(Collectors.joining(join == null ? "" : join));
        }
    }

转载于:https://www.cnblogs.com/beyond-MS/p/10791319.html