栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 面试经验 > 面试问答

等价于Scala drop

面试问答 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

等价于Scala drop

这种操作不是

Stream
s 的预期用例,因为它并入了元素之间的依赖关系。因此,该解决方案可能看起来不太好,因为您必须为谓词引入一个全状态变量:

class MutableBoolean { boolean b; }MutableBoolean inTail = new MutableBoolean();IntStream.of(0, 1, 2, 3, 0, 1, 2, 3, 4)         .filter(i -> inTail.b || i >= 3 && (inTail.b = true))         .forEach(System.out::println);

请注意,与您的示例相比,该条件必须颠倒。

当然,您可以在方法中隐藏令人讨厌的细节:

public static void main(String... arg) {    dropWhile(n -> n < 3, Stream.of(0, 1, 2, 3, 0, 1, 2, 3, 4))      .forEach(System.out::println);}static <T> Stream<T> dropWhile(Predicate<T> p, Stream<T> s) {    class MutableBoolean { boolean b; }    MutableBoolean inTail = new MutableBoolean();    return s.filter(i -> inTail.b || !p.test(i) && (inTail.b = true));}

一个更复杂,但更清洁,可能更有效的方法是深入研究金属,即

Spliterator
界面:

static <T> Stream<T> dropWhile(Predicate<T> p, Stream<T> s) {    Spliterator<T> sp = s.spliterator();    return StreamSupport.stream(new Spliterators.AbstractSpliterator<T>( sp.estimateSize(), sp.characteristics() & ~Spliterator.SIZED) {        boolean dropped;        public boolean tryAdvance(Consumer<? super T> action) { if(dropped) return sp.tryAdvance(action); do {} while(!dropped && sp.tryAdvance(t -> {     if(!p.test(t)) {         dropped=true;         action.accept(t);     } })); return dropped;        }        public void forEachRemaining(Consumer<? super T> action) { while(!dropped) if(!tryAdvance(action)) return; sp.forEachRemaining(action);        }    }, s.isParallel());}

可以使用与第

dropWhile
一种方法相同的方法,但是即使并行流也可以使用,尽管效率不如您期望的那样。



转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/486018.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号