ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/main/java/util/PriorityQueue.java
(Generate patch)

Comparing jsr166/src/main/java/util/PriorityQueue.java (file contents):
Revision 1.112 by jsr166, Tue Nov 29 18:11:28 2016 UTC vs.
Revision 1.113 by jsr166, Wed Nov 30 03:31:47 2016 UTC

# Line 813 | Line 813 | public class PriorityQueue<E> extends Ab
813       * @since 1.8
814       */
815      public final Spliterator<E> spliterator() {
816 <        return new PriorityQueueSpliterator<>(this, 0, -1, 0);
816 >        return new PriorityQueueSpliterator(0, -1, 0);
817      }
818  
819 <    static final class PriorityQueueSpliterator<E> implements Spliterator<E> {
819 >    final class PriorityQueueSpliterator implements Spliterator<E> {
820          /*
821           * This is very similar to ArrayList Spliterator, except for
822           * extra null checks.
823           */
824 –        private final PriorityQueue<E> pq;
824          private int index;            // current index, modified on advance/split
825          private int fence;            // -1 until first use
826          private int expectedModCount; // initialized when fence set
827  
828          /** Creates new spliterator covering the given range. */
829 <        PriorityQueueSpliterator(PriorityQueue<E> pq, int origin, int fence,
831 <                                 int expectedModCount) {
832 <            this.pq = pq;
829 >        PriorityQueueSpliterator(int origin, int fence, int expectedModCount) {
830              this.index = origin;
831              this.fence = fence;
832              this.expectedModCount = expectedModCount;
# Line 838 | Line 835 | public class PriorityQueue<E> extends Ab
835          private int getFence() { // initialize fence to size on first use
836              int hi;
837              if ((hi = fence) < 0) {
838 <                expectedModCount = pq.modCount;
839 <                hi = fence = pq.size;
838 >                expectedModCount = modCount;
839 >                hi = fence = size;
840              }
841              return hi;
842          }
843  
844 <        public PriorityQueueSpliterator<E> trySplit() {
844 >        public PriorityQueueSpliterator trySplit() {
845              int hi = getFence(), lo = index, mid = (lo + hi) >>> 1;
846              return (lo >= mid) ? null :
847 <                new PriorityQueueSpliterator<>(pq, lo, index = mid,
851 <                                               expectedModCount);
847 >                new PriorityQueueSpliterator(lo, index = mid, expectedModCount);
848          }
849  
850          @SuppressWarnings("unchecked")
851          public void forEachRemaining(Consumer<? super E> action) {
852              int i, hi, mc; // hoist accesses and checks from loop
853 <            PriorityQueue<E> q; Object[] a;
853 >            final Object[] a;
854              if (action == null)
855                  throw new NullPointerException();
856 <            if ((q = pq) != null && (a = q.queue) != null) {
856 >            if ((a = queue) != null) {
857                  if ((hi = fence) < 0) {
858 <                    mc = q.modCount;
859 <                    hi = q.size;
858 >                    mc = modCount;
859 >                    hi = size;
860                  }
861                  else
862                      mc = expectedModCount;
# Line 871 | Line 867 | public class PriorityQueue<E> extends Ab
867                                  break;
868                              action.accept(e);
869                          }
870 <                        else if (q.modCount != mc)
870 >                        else if (modCount != mc)
871                              break;
872                          else
873                              return;
# Line 887 | Line 883 | public class PriorityQueue<E> extends Ab
883              int hi = getFence(), lo = index;
884              if (lo >= 0 && lo < hi) {
885                  index = lo + 1;
886 <                @SuppressWarnings("unchecked") E e = (E)pq.queue[lo];
886 >                @SuppressWarnings("unchecked") E e = (E)queue[lo];
887                  if (e == null)
888                      throw new ConcurrentModificationException();
889                  action.accept(e);
890 <                if (pq.modCount != expectedModCount)
890 >                if (modCount != expectedModCount)
891                      throw new ConcurrentModificationException();
892                  return true;
893              }
# Line 899 | Line 895 | public class PriorityQueue<E> extends Ab
895          }
896  
897          public long estimateSize() {
898 <            return (long) (getFence() - index);
898 >            return getFence() - index;
899          }
900  
901          public int characteristics() {

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines