Class UnorderedCancellableSpliterator<T,​A>

    • Nested Class Summary

      • Nested classes/interfaces inherited from interface java.util.Spliterator

        java.util.Spliterator.OfDouble, java.util.Spliterator.OfInt, java.util.Spliterator.OfLong, java.util.Spliterator.OfPrimitive<T extends java.lang.Object,​T_CONS extends java.lang.Object,​T_SPLITR extends java.util.Spliterator.OfPrimitive<T,​T_CONS,​T_SPLITR>>
    • Field Summary

      Fields 
      Modifier and Type Field Description
      private java.util.function.BiConsumer<A,​? super T> accumulator  
      private java.util.concurrent.atomic.AtomicBoolean cancelled  
      private java.util.function.Predicate<A> cancelPredicate  
      private java.util.function.BinaryOperator<A> combiner  
      private boolean flag  
      private java.util.concurrent.atomic.AtomicInteger nPeers  
      private java.util.concurrent.ConcurrentLinkedQueue<A> partialResults  
      private java.util.Spliterator<T> source  
      private java.util.function.Supplier<A> supplier  
      • Fields inherited from interface java.util.Spliterator

        CONCURRENT, DISTINCT, IMMUTABLE, NONNULL, ORDERED, SIZED, SORTED, SUBSIZED
    • Constructor Summary

      Constructors 
      Constructor Description
      UnorderedCancellableSpliterator​(java.util.Spliterator<T> source, java.util.function.Supplier<A> supplier, java.util.function.BiConsumer<A,​? super T> accumulator, java.util.function.BinaryOperator<A> combiner, java.util.function.Predicate<A> cancelPredicate)  
    • Field Detail

      • source

        private volatile java.util.Spliterator<T> source
      • accumulator

        private final java.util.function.BiConsumer<A,​? super T> accumulator
      • cancelPredicate

        private final java.util.function.Predicate<A> cancelPredicate
      • supplier

        private final java.util.function.Supplier<A> supplier
      • partialResults

        private final java.util.concurrent.ConcurrentLinkedQueue<A> partialResults
      • cancelled

        private final java.util.concurrent.atomic.AtomicBoolean cancelled
      • nPeers

        private final java.util.concurrent.atomic.AtomicInteger nPeers
      • combiner

        private final java.util.function.BinaryOperator<A> combiner
      • flag

        private boolean flag
    • Constructor Detail

      • UnorderedCancellableSpliterator

        UnorderedCancellableSpliterator​(java.util.Spliterator<T> source,
                                        java.util.function.Supplier<A> supplier,
                                        java.util.function.BiConsumer<A,​? super T> accumulator,
                                        java.util.function.BinaryOperator<A> combiner,
                                        java.util.function.Predicate<A> cancelPredicate)
    • Method Detail

      • checkCancel

        private boolean checkCancel​(A acc)
      • handleCancel

        private boolean handleCancel​(java.util.function.Consumer<? super A> action,
                                     A acc)
      • tryAdvance

        public boolean tryAdvance​(java.util.function.Consumer<? super A> action)
      • forEachRemaining

        public void forEachRemaining​(java.util.function.Consumer<? super A> action)
      • trySplit

        public java.util.Spliterator<A> trySplit()
      • estimateSize

        public long estimateSize()
      • characteristics

        public int characteristics()