public class FlowControlLinkedTransferQueue extends LinkedTransferQueue<WriteMessage>
LinkedTransferQueue.PaddedAtomicReference<T>
Constructor and Description |
---|
FlowControlLinkedTransferQueue(FlowControl flowControl) |
Modifier and Type | Method and Description |
---|---|
int |
drainTo(Collection<? super WriteMessage> c) |
int |
drainTo(Collection<? super WriteMessage> c,
int maxElements) |
int |
getWaitingConsumerCount() |
boolean |
hasWaitingConsumer() |
boolean |
isEmpty() |
Iterator<WriteMessage> |
iterator() |
boolean |
offer(WriteMessage e) |
boolean |
offer(WriteMessage e,
long timeout,
TimeUnit unit) |
WriteMessage |
peek() |
WriteMessage |
poll() |
WriteMessage |
poll(long timeout,
TimeUnit unit) |
void |
put(WriteMessage e) |
int |
remainingCapacity() |
int |
size()
Returns the number of elements in this queue.
|
WriteMessage |
take() |
void |
transfer(WriteMessage e) |
boolean |
tryTransfer(WriteMessage e) |
boolean |
tryTransfer(WriteMessage e,
long timeout,
TimeUnit unit) |
contains, containsAll, remove, removeAll, retainAll, toArray, toArray, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
add, contains, remove
addAll, clear, containsAll, equals, hashCode, removeAll, retainAll, toArray, toArray
public FlowControlLinkedTransferQueue(FlowControl flowControl)
public void put(WriteMessage e) throws InterruptedException
put
in interface BlockingQueue<WriteMessage>
put
in class LinkedTransferQueue<WriteMessage>
InterruptedException
public boolean offer(WriteMessage e, long timeout, TimeUnit unit) throws InterruptedException
offer
in interface BlockingQueue<WriteMessage>
offer
in class LinkedTransferQueue<WriteMessage>
InterruptedException
public boolean offer(WriteMessage e)
offer
in interface BlockingQueue<WriteMessage>
offer
in interface Queue<WriteMessage>
offer
in class LinkedTransferQueue<WriteMessage>
public void transfer(WriteMessage e) throws InterruptedException
transfer
in class LinkedTransferQueue<WriteMessage>
InterruptedException
public boolean tryTransfer(WriteMessage e, long timeout, TimeUnit unit) throws InterruptedException
tryTransfer
in class LinkedTransferQueue<WriteMessage>
InterruptedException
public boolean tryTransfer(WriteMessage e)
tryTransfer
in class LinkedTransferQueue<WriteMessage>
public WriteMessage take() throws InterruptedException
take
in interface BlockingQueue<WriteMessage>
take
in class LinkedTransferQueue<WriteMessage>
InterruptedException
public WriteMessage poll(long timeout, TimeUnit unit) throws InterruptedException
poll
in interface BlockingQueue<WriteMessage>
poll
in class LinkedTransferQueue<WriteMessage>
InterruptedException
public WriteMessage poll()
poll
in interface Queue<WriteMessage>
poll
in class LinkedTransferQueue<WriteMessage>
public int drainTo(Collection<? super WriteMessage> c)
drainTo
in interface BlockingQueue<WriteMessage>
drainTo
in class LinkedTransferQueue<WriteMessage>
public int drainTo(Collection<? super WriteMessage> c, int maxElements)
drainTo
in interface BlockingQueue<WriteMessage>
drainTo
in class LinkedTransferQueue<WriteMessage>
public Iterator<WriteMessage> iterator()
iterator
in interface Iterable<WriteMessage>
iterator
in interface Collection<WriteMessage>
iterator
in class LinkedTransferQueue<WriteMessage>
public WriteMessage peek()
peek
in interface Queue<WriteMessage>
peek
in class LinkedTransferQueue<WriteMessage>
public boolean isEmpty()
isEmpty
in interface Collection<WriteMessage>
isEmpty
in class LinkedTransferQueue<WriteMessage>
public boolean hasWaitingConsumer()
hasWaitingConsumer
in class LinkedTransferQueue<WriteMessage>
public int size()
LinkedTransferQueue
Beware that, unlike in most collections, this method is NOT a constant-time operation. Because of the asynchronous nature of these queues, determining the current number of elements requires an O(n) traversal.
size
in interface Collection<WriteMessage>
size
in class LinkedTransferQueue<WriteMessage>
public int getWaitingConsumerCount()
getWaitingConsumerCount
in class LinkedTransferQueue<WriteMessage>
public int remainingCapacity()
remainingCapacity
in interface BlockingQueue<WriteMessage>
remainingCapacity
in class LinkedTransferQueue<WriteMessage>
Copyright © 2021. All rights reserved.