com.couchbase.lite.support

Class CustomLinkedBlockingQueue<E>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<E>

java.util.concurrent.LinkedBlockingQueue<E>

com.couchbase.lite.support.CustomLinkedBlockingQueue<E>

All Implemented Interfaces:

java.io.Serializable, java.lang.Iterable<E>, java.util.Collection<E>, java.util.concurrent.BlockingQueue<E>, java.util.Queue<E>

public class CustomLinkedBlockingQueue<E>
extends java.util.concurrent.LinkedBlockingQueue<E>

Created by hideki on 12/17/14.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CustomLinkedBlockingQueue()
CustomLinkedBlockingQueue(BlockingQueueListener listener)
CustomLinkedBlockingQueue(java.util.Collection c)
CustomLinkedBlockingQueue(int capacity)

Method Summary

Modifier and Type	Method and Description
boolean	add(E e)
BlockingQueueListener	getListener()
E	poll()
E	poll(long timeout, java.util.concurrent.TimeUnit unit)
void	put(E e)
void	setListener(BlockingQueueListener listener)
E	take()

Methods inherited from class java.util.concurrent.LinkedBlockingQueue

clear, contains, drainTo, drainTo, iterator, offer, offer, peek, remainingCapacity, remove, size, spliterator, toArray, toArray, toString

Methods inherited from class java.util.AbstractQueue

addAll, element, remove

Methods inherited from class java.util.AbstractCollection

containsAll, isEmpty, removeAll, retainAll

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Queue

element, remove

Methods inherited from interface java.util.Collection

addAll, containsAll, equals, hashCode, isEmpty, parallelStream, removeAll, removeIf, retainAll, stream

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

CustomLinkedBlockingQueue

public CustomLinkedBlockingQueue()

CustomLinkedBlockingQueue

public CustomLinkedBlockingQueue(BlockingQueueListener listener)

CustomLinkedBlockingQueue

public CustomLinkedBlockingQueue(int capacity)

CustomLinkedBlockingQueue

public CustomLinkedBlockingQueue(java.util.Collection c)

Method Detail

getListener

public BlockingQueueListener getListener()

setListener

public void setListener(BlockingQueueListener listener)

put

public void put(E e)
         throws java.lang.InterruptedException

Specified by:

put in interface java.util.concurrent.BlockingQueue<E>

Overrides:

put in class java.util.concurrent.LinkedBlockingQueue<E>

Throws:

java.lang.InterruptedException

add

public boolean add(E e)

Specified by:

add in interface java.util.Collection<E>

Specified by:

add in interface java.util.concurrent.BlockingQueue<E>

Specified by:

add in interface java.util.Queue<E>

Overrides:

add in class java.util.AbstractQueue<E>

take

public E take()
       throws java.lang.InterruptedException

Specified by:

take in interface java.util.concurrent.BlockingQueue<E>

Overrides:

take in class java.util.concurrent.LinkedBlockingQueue<E>

Throws:

java.lang.InterruptedException

poll

public E poll(long timeout,
              java.util.concurrent.TimeUnit unit)
       throws java.lang.InterruptedException

Specified by:

poll in interface java.util.concurrent.BlockingQueue<E>

Overrides:

poll in class java.util.concurrent.LinkedBlockingQueue<E>

Throws:

java.lang.InterruptedException

poll

public E poll()

Specified by:

poll in interface java.util.Queue<E>

Overrides:

poll in class java.util.concurrent.LinkedBlockingQueue<E>