Java8流式类层次结构

Question

我正在慢慢学习Java 8的新功能，并试图找到一种以流方式处理类层次结构（从子级到父级）的方法。

例如，在类或其父级上找到注释。

在Java 8之前，我会这样完成：

public static <T extends Annotation> T getAnnonationOn(Class<?> type, Class<T> annType) {
    Class<?> t = type;
    T annot = null;
    while (t != null && annot == null) {
        annot = t.getAnnotation(annType);
        t = t.getSuperclass();
    }
    return annot;
}

现在，我希望以一种更加“功能性的编程”方式来做到这一点。我找不到比使用以下递归连接流更好的方法：

import java.lang.annotation.Annotation;
import java.util.stream.Stream;

public static <T extends Annotation> T getAnnonationOn(Class<?> type, Class<T> annType) {
    return ClassIterator.streamSuperclass(type)
        .map(t -> t.getAnnotation(annType))
        .filter(a -> a != null)
        .findFirst()
        .orElse(null);
}

public static class ClassIterator {
    public static Stream<Class<?>> streamSuperclass(Class<?> type) {
        if (type.getSuperclass() != null) {
            return Stream.concat(Stream.of(type), Stream.of(type.getSuperclass()).flatMap(ClassIterator::streamSuperclass));
        }
        return Stream.of(type);
    }
}

但是我对解决方案并不满意。尽管我没有进行基准测试，但我认为流连接非常麻烦且性能低下。

是否有更好的方法将递归转换为流？

Answer 1

在Java 9中，您可能会使用

public static Stream<Class<?>> streamSuperclass(Class<?> type) {
    return Stream.iterate(type, Objects::nonNull, Class::getSuperclass);
}

但是在Java 8中，此功能不可用，因此您可以求助于手动实现Stream：

public static Stream<Class<?>> streamSuperclass(Class<?> type) {
    return StreamSupport.stream(
        new Spliterators.AbstractSpliterator<Class<?>>(100L,
            Spliterator.ORDERED|Spliterator.IMMUTABLE|Spliterator.NONNULL) {
            Class<?> current = type;
            public boolean tryAdvance(Consumer<? super Class<?>> action) {
                if(current == null) return false;
                action.accept(current);
                current = current.getSuperclass();
                return true;
            }
        }, false);
}

请注意，这将从最具体的类型流向java.lang.Object。如果要使顺序从Object最具体的顺序开始，则没有办法首先收集元素（无论是递归还是迭代）不是很重要，但Stream.concat实际上是性能最低的一种。您可以简单地使用

public static Stream<Class<?>> streamSuperclass(Class<?> type) {
    return reverse(Stream.<Class<?>>builder(), type, Class::getSuperclass).build();
}
private static <T> Stream.Builder<T> reverse(
        Stream.Builder<T> builder, T t, UnaryOperator<T> op) {
    return t==null? builder: reverse(builder, op.apply(t), op).add(t);
}

迭代变体也不错：

public static Stream<Class<?>> streamSuperclass(Class<?> type) {
    List<Class<?>> l=new ArrayList<>();
    for(; type!=null; type=type.getSuperclass()) l.add(type);
    Collections.reverse(l);
    return l.stream();
}

对于像典型的类层次结构一样小的流，an ArrayList并不比a差Stream.Builder，对于非常大的流，使用递归填充生成器也不是最佳解决方案……