Package net.rubyeye.xmemcached.impl

Class FlowControlLinkedTransferQueue

java.lang.Object

java.util.AbstractCollection<WriteMessage>

java.util.AbstractQueue<WriteMessage>

com.google.code.yanf4j.util.LinkedTransferQueue<WriteMessage>

net.rubyeye.xmemcached.impl.FlowControlLinkedTransferQueue

All Implemented Interfaces:

Iterable<WriteMessage>, Collection<WriteMessage>, BlockingQueue<WriteMessage>, Queue<WriteMessage>

public class FlowControlLinkedTransferQueue
extends LinkedTransferQueue<WriteMessage>

Nested Class Summary

Nested classes/interfaces inherited from class com.google.code.yanf4j.util.LinkedTransferQueue

LinkedTransferQueue.PaddedAtomicReference<T>

Field Summary

Fields

Modifier and Type	Field	Description
private FlowControl	flowControl

Constructor Summary

Constructors

Constructor	Description
FlowControlLinkedTransferQueue(FlowControl flowControl)

Method Summary

Modifier and Type	Method	Description
private void	checkPermits(WriteMessage e)
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)
private void	releasePermit(WriteMessage rt)
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)

Methods inherited from class java.util.AbstractQueue

add, addAll, clear, element, remove

Methods inherited from class java.util.AbstractCollection

contains, containsAll, remove, removeAll, retainAll, toArray, toArray, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.BlockingQueue

add, contains, remove

Methods inherited from interface java.util.Collection

addAll, clear, containsAll, equals, hashCode, parallelStream, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface java.util.Queue

element, remove

Field Details

flowControl

private FlowControl flowControl

Constructor Details

FlowControlLinkedTransferQueue

public FlowControlLinkedTransferQueue(FlowControl flowControl)

Method Details

checkPermits

private void checkPermits(WriteMessage e)

put

public void put(WriteMessage e)
         throws InterruptedException

Specified by:

put in interface BlockingQueue<WriteMessage>

Overrides:

put in class LinkedTransferQueue<WriteMessage>

Throws:

InterruptedException

offer

public boolean offer(WriteMessage e,
 long timeout,
 TimeUnit unit)
              throws InterruptedException

Specified by:

offer in interface BlockingQueue<WriteMessage>

Overrides:

offer in class LinkedTransferQueue<WriteMessage>

Throws:

InterruptedException

offer

public boolean offer(WriteMessage e)

Specified by:

offer in interface BlockingQueue<WriteMessage>

Specified by:

offer in interface Queue<WriteMessage>

Overrides:

offer in class LinkedTransferQueue<WriteMessage>

transfer

public void transfer(WriteMessage e)
              throws InterruptedException

Overrides:

transfer in class LinkedTransferQueue<WriteMessage>

Throws:

InterruptedException

tryTransfer

public boolean tryTransfer(WriteMessage e,
 long timeout,
 TimeUnit unit)
                    throws InterruptedException

Overrides:

tryTransfer in class LinkedTransferQueue<WriteMessage>

Throws:

InterruptedException

tryTransfer

public boolean tryTransfer(WriteMessage e)

Overrides:

tryTransfer in class LinkedTransferQueue<WriteMessage>

take

public WriteMessage take()
                  throws InterruptedException

Specified by:

take in interface BlockingQueue<WriteMessage>

Overrides:

take in class LinkedTransferQueue<WriteMessage>

Throws:

InterruptedException

poll

public WriteMessage poll(long timeout,
 TimeUnit unit)
                  throws InterruptedException

Specified by:

poll in interface BlockingQueue<WriteMessage>

Overrides:

poll in class LinkedTransferQueue<WriteMessage>

Throws:

InterruptedException

poll

public WriteMessage poll()

Specified by:

poll in interface Queue<WriteMessage>

Overrides:

poll in class LinkedTransferQueue<WriteMessage>

releasePermit

private void releasePermit(WriteMessage rt)

drainTo

public int drainTo(Collection<? super WriteMessage> c)

Specified by:

drainTo in interface BlockingQueue<WriteMessage>

Overrides:

drainTo in class LinkedTransferQueue<WriteMessage>

drainTo

public int drainTo(Collection<? super WriteMessage> c,
 int maxElements)

Specified by:

drainTo in interface BlockingQueue<WriteMessage>

Overrides:

drainTo in class LinkedTransferQueue<WriteMessage>

iterator

public Iterator<WriteMessage> iterator()

Specified by:

iterator in interface Collection<WriteMessage>

Specified by:

iterator in interface Iterable<WriteMessage>

Overrides:

iterator in class LinkedTransferQueue<WriteMessage>

peek

public WriteMessage peek()

Specified by:

peek in interface Queue<WriteMessage>

Overrides:

peek in class LinkedTransferQueue<WriteMessage>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Collection<WriteMessage>

Overrides:

isEmpty in class LinkedTransferQueue<WriteMessage>

hasWaitingConsumer

public boolean hasWaitingConsumer()

Overrides:

hasWaitingConsumer in class LinkedTransferQueue<WriteMessage>

size

public int size()

Description copied from class: LinkedTransferQueue

Returns the number of elements in this queue. If this queue contains more than Integer.MAX_VALUE elements, returns Integer.MAX_VALUE.

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.

Specified by:

size in interface Collection<WriteMessage>

Overrides:

size in class LinkedTransferQueue<WriteMessage>

Returns:

the number of elements in this queue

getWaitingConsumerCount

public int getWaitingConsumerCount()

Overrides:

getWaitingConsumerCount in class LinkedTransferQueue<WriteMessage>

remainingCapacity

public int remainingCapacity()

Specified by:

remainingCapacity in interface BlockingQueue<WriteMessage>

Overrides:

remainingCapacity in class LinkedTransferQueue<WriteMessage>