本文共 1521 字,大约阅读时间需要 5 分钟。
**
@param <T>
*/static class GroupToList<T> implements Collector<T, List<List<T>>, List<List<T>>> { /**集合中对象两两比较,满足自定义的条件(operation结果返回true),便将这两个元素分为一组
*/private BiFunction<T, T, Boolean> operation;public GroupToList(BiFunction<T, T, Boolean> operation) {
super();this.operation = operation;}@Override
public BiConsumer<List<List<T>>, T> accumulator() { return (c, t) -> { boolean added = false;for (List<T> cc : c) { for (T ccc : cc) { if (operation.apply(ccc, t)){ cc.add(t);added = true;}break;}if (added)break;continue;}if (!added) { ArrayList<T> list = new ArrayList<T>();list.add(t);c.add(list);}};}@Override
public Set<java.util.stream.Collector.Characteristics> characteristics() { /Set<java.util.stream.Collector.Characteristics> emptySet = Collections.emptySet();/return Collections.unmodifiableSet(EnumSet.of(Characteristics.IDENTITY_FINISH));}@Override
public BinaryOperator<List<List<T>>> combiner() { return (l1,l2) -> {l2.addAll(l1); return l2;};}@Override
public Function<List<List<T>>, List<List<T>>> finisher() { return p -> p;}@Override
public Supplier<List<List<T>>> supplier() { return () -> new ArrayList<List<T>>(); 欢迎工作一到五年的Java工程师朋友们加入Java群: 891219277群内提供免费的Java架构学习资料(里面有高可用、高并发、高性能及分布式、Jvm性能调优、Spring源码,MyBatis,Netty,Redis,Kafka,Mysql,Zookeeper,Tomcat,Docker,Dubbo,Nginx等多个知识点的架构资料)合理利用自己每一分每一秒的时间来学习提升自己,不要再用"没有时间“来掩饰自己思想上的懒惰!趁年轻,使劲拼,给未来的自己一个交代!}
}复制代码转载于:https://blog.51cto.com/14084556/2343026