| 27 |
|
import java.util.stream.Stream; |
| 28 |
|
import java.util.Spliterator; |
| 29 |
|
import java.util.stream.Streams; |
| 30 |
< |
import java.util.function.Block; |
| 30 |
> |
import java.util.function.Consumer; |
| 31 |
|
|
| 32 |
|
/** |
| 33 |
|
* An unbounded priority {@linkplain Queue queue} based on a priority heap. |
| 64 |
|
* Multiple threads should not access a {@code PriorityQueue} |
| 65 |
|
* instance concurrently if any of the threads modifies the queue. |
| 66 |
|
* Instead, use the thread-safe {@link |
| 67 |
< |
* java.util.concurrent.PriorityBlockingQueue} class. |
| 67 |
> |
* java.util.concurrent.PriorityConsumeringQueue} class. |
| 68 |
|
* |
| 69 |
|
* <p>Implementation note: this implementation provides |
| 70 |
|
* O(log(n)) time for the enqueing and dequeing methods |
| 453 |
|
*/ |
| 454 |
|
@SuppressWarnings("unchecked") |
| 455 |
|
public <T> T[] toArray(T[] a) { |
| 456 |
+ |
final int size = this.size; |
| 457 |
|
if (a.length < size) |
| 458 |
|
// Make a new array of a's runtime type, but my contents: |
| 459 |
|
return (T[]) Arrays.copyOf(queue, size, a.getClass()); |
| 803 |
|
} |
| 804 |
|
|
| 805 |
|
/** Index-based split-by-two Spliterator */ |
| 806 |
< |
static final class PriorityQueueSpliterator<E> |
| 806 |
< |
implements Spliterator<E>, Iterator<E> { |
| 806 |
> |
static final class PriorityQueueSpliterator<E> implements Spliterator<E> { |
| 807 |
|
private final PriorityQueue<E> pq; |
| 808 |
|
private int index; // current index, modified on advance/split |
| 809 |
|
private final int fence; // one past last index |
| 820 |
|
int lo = index, mid = (lo + fence) >>> 1; |
| 821 |
|
return (lo >= mid) ? null : |
| 822 |
|
new PriorityQueueSpliterator<E>(pq, lo, index = mid, |
| 823 |
< |
expectedModCount); |
| 823 |
> |
expectedModCount); |
| 824 |
|
} |
| 825 |
|
|
| 826 |
< |
public void forEach(Block<? super E> block) { |
| 826 |
> |
public void forEach(Consumer<? super E> block) { |
| 827 |
|
Object[] a; int i, hi; // hoist accesses and checks from loop |
| 828 |
|
if (block == null) |
| 829 |
|
throw new NullPointerException(); |
| 839 |
|
} |
| 840 |
|
} |
| 841 |
|
|
| 842 |
< |
public boolean tryAdvance(Block<? super E> block) { |
| 842 |
> |
public boolean tryAdvance(Consumer<? super E> block) { |
| 843 |
|
if (index >= 0 && index < fence) { |
| 844 |
– |
if (pq.modCount != expectedModCount) |
| 845 |
– |
throw new ConcurrentModificationException(); |
| 844 |
|
@SuppressWarnings("unchecked") E e = |
| 845 |
|
(E)pq.queue[index++]; |
| 846 |
|
block.accept(e); |
| 847 |
+ |
if (pq.modCount != expectedModCount) |
| 848 |
+ |
throw new ConcurrentModificationException(); |
| 849 |
|
return true; |
| 850 |
|
} |
| 851 |
|
return false; |
| 854 |
|
public long estimateSize() { return (long)(fence - index); } |
| 855 |
|
public boolean hasExactSize() { return true; } |
| 856 |
|
public boolean hasExactSplits() { return true; } |
| 857 |
– |
|
| 858 |
– |
// Iterator support |
| 859 |
– |
public Iterator<E> iterator() { return this; } |
| 860 |
– |
public void remove() { throw new UnsupportedOperationException(); } |
| 861 |
– |
public boolean hasNext() { return index >= 0 && index < fence; } |
| 862 |
– |
|
| 863 |
– |
public E next() { |
| 864 |
– |
if (index < 0 || index >= fence) |
| 865 |
– |
throw new NoSuchElementException(); |
| 866 |
– |
if (pq.modCount != expectedModCount) |
| 867 |
– |
throw new ConcurrentModificationException(); |
| 868 |
– |
@SuppressWarnings("unchecked") E e = |
| 869 |
– |
(E) pq.queue[index++]; |
| 870 |
– |
return e; |
| 871 |
– |
} |
| 857 |
|
} |
| 858 |
|
} |
