public final class CompletableLinkedQueue<T> extends LinkedTransferQueue<T> implements CompletableQueue<T>
Constructor and Description |
---|
CompletableLinkedQueue() |
Modifier and Type | Method and Description |
---|---|
void |
complete()
Mark this queue as complete
|
boolean |
isComplete()
Get the number of items persisted right now.
|
add, contains, drainTo, drainTo, getWaitingConsumerCount, hasWaitingConsumer, isEmpty, iterator, offer, offer, peek, poll, poll, put, remainingCapacity, remove, size, spliterator, take, transfer, tryTransfer, tryTransfer
addAll, clear, element, remove
containsAll, removeAll, retainAll, toArray, toArray, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
addAll, clear, contains, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray
public void complete()
CompletableQueue
complete
in interface CompletableQueue<T>
public boolean isComplete()
CompletableQueue
isComplete
in interface CompletableQueue<T>
this#complete()
Copyright © 2017. All rights reserved.