com.screenscraper.concurrent

Class ResizeableLinkedBlockingDeque<T>

java.lang.Object

com.screenscraper.concurrent.ResizeableLinkedBlockingDeque<T>

All Implemented Interfaces:

java.lang.Iterable<T>, java.util.Collection<T>, java.util.concurrent.BlockingDeque<T>, java.util.concurrent.BlockingQueue<T>, java.util.Deque<T>, java.util.Queue<T>

public class ResizeableLinkedBlockingDeque<T>
extends java.lang.Object
implements java.util.concurrent.BlockingDeque<T>

A LinkedBlockingDeque with a scalable capacity. This class is thread safe

Version:

1.0

Constructor Summary

Constructors

Constructor and Description
ResizeableLinkedBlockingDeque() Creates an unbounded deque
ResizeableLinkedBlockingDeque(int capacity) Creates a deque with the specified capacity

Method Summary

Modifier and Type	Method and Description
boolean	add(T t)
boolean	addAll(java.util.Collection<? extends T> collection)
void	addFirst(T t)
void	addFirstForce(T t) Adds the given element to the beginning of the dequeue regardless of capacity restrictions
void	addLast(T t)
void	addLastForce(T t) Adds the given element to the end of the dequeue regardless of capacity restrictions
void	clear()
boolean	contains(java.lang.Object o)
boolean	containsAll(java.util.Collection<?> collection)
java.util.Iterator<T>	descendingIterator()
int	drainTo(java.util.Collection<? super T> collection)
int	drainTo(java.util.Collection<? super T> collection, int maxElements)
T	element()
int	getCapacity() Returns the Capacity for the object
T	getFirst()
T	getLast()
boolean	isEmpty()
java.util.Iterator<T>	iterator()
boolean	offer(T t)
boolean	offer(T t, long timeout, java.util.concurrent.TimeUnit unit)
boolean	offerFirst(T t)
boolean	offerFirst(T t, long timeout, java.util.concurrent.TimeUnit unit)
boolean	offerLast(T t)
boolean	offerLast(T t, long timeout, java.util.concurrent.TimeUnit unit)
T	peek()
T	peekFirst()
T	peekLast()
T	poll()
T	poll(long timeout, java.util.concurrent.TimeUnit unit)
T	pollFirst()
T	pollFirst(long timeout, java.util.concurrent.TimeUnit unit)
T	pollLast()
T	pollLast(long timeout, java.util.concurrent.TimeUnit unit)
T	pop()
void	push(T t)
void	put(T t)
void	putFirst(T t)
void	putLast(T t)
int	remainingCapacity()
T	remove()
boolean	remove(java.lang.Object o)
boolean	removeAll(java.util.Collection<?> collection)
T	removeFirst()
boolean	removeFirstOccurrence(java.lang.Object o)
T	removeLast()
boolean	removeLastOccurrence(java.lang.Object o)
boolean	retainAll(java.util.Collection<?> collection)
void	setCapacity(int capacity) Sets the Capacity for the object
int	size()
T	take()
T	takeFirst()
T	takeLast()
java.lang.Object[]	toArray()
<U> U[]	toArray(U[] writeArray)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Collection

equals, hashCode, parallelStream, removeIf, spliterator, stream

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

ResizeableLinkedBlockingDeque

public ResizeableLinkedBlockingDeque()

Creates an unbounded deque

ResizeableLinkedBlockingDeque

public ResizeableLinkedBlockingDeque(int capacity)

Creates a deque with the specified capacity

Parameters:

capacity - The capacity of the deque (negative means infinite). Must not be 0

Method Detail

getCapacity

public int getCapacity()

Returns the Capacity for the object

Returns:

The Capacity for the object

setCapacity

public void setCapacity(int capacity)

Sets the Capacity for the object

Parameters:

capacity - The new value for Capacity (negative for infinite, must be non-zero)

addFirst

public void addFirst(@NotNull
                     T t)

Specified by:

addFirst in interface java.util.concurrent.BlockingDeque<T>

Specified by:

addFirst in interface java.util.Deque<T>

addLast

public void addLast(@NotNull
                    T t)

Specified by:

addLast in interface java.util.concurrent.BlockingDeque<T>

Specified by:

addLast in interface java.util.Deque<T>

offerFirst

public boolean offerFirst(@NotNull
                          T t)

Specified by:

offerFirst in interface java.util.concurrent.BlockingDeque<T>

Specified by:

offerFirst in interface java.util.Deque<T>

offerLast

public boolean offerLast(@NotNull
                         T t)

Specified by:

offerLast in interface java.util.concurrent.BlockingDeque<T>

Specified by:

offerLast in interface java.util.Deque<T>

removeFirst

@NotNull
public T removeFirst()

Specified by:

removeFirst in interface java.util.Deque<T>

removeLast

@NotNull
public T removeLast()

Specified by:

removeLast in interface java.util.Deque<T>

pollFirst

@Nullable
public T pollFirst()

Specified by:

pollFirst in interface java.util.Deque<T>

pollLast

@Nullable
public T pollLast()

Specified by:

pollLast in interface java.util.Deque<T>

getFirst

@NotNull
public T getFirst()

Specified by:

getFirst in interface java.util.Deque<T>

getLast

@NotNull
public T getLast()

Specified by:

getLast in interface java.util.Deque<T>

peekFirst

@Nullable
public T peekFirst()

Specified by:

peekFirst in interface java.util.Deque<T>

peekLast

@Nullable
public T peekLast()

Specified by:

peekLast in interface java.util.Deque<T>

putFirst

public void putFirst(T t)
              throws java.lang.InterruptedException

Specified by:

putFirst in interface java.util.concurrent.BlockingDeque<T>

Throws:

java.lang.InterruptedException

putLast

public void putLast(T t)
             throws java.lang.InterruptedException

Specified by:

putLast in interface java.util.concurrent.BlockingDeque<T>

Throws:

java.lang.InterruptedException

addFirstForce

public void addFirstForce(T t)

Adds the given element to the beginning of the dequeue regardless of capacity restrictions

Parameters:

t - The element to add

addLastForce

public void addLastForce(T t)

Adds the given element to the end of the dequeue regardless of capacity restrictions

Parameters:

t - The element to add

offerFirst

public boolean offerFirst(T t,
                          long timeout,
                          java.util.concurrent.TimeUnit unit)
                   throws java.lang.InterruptedException

Specified by:

offerFirst in interface java.util.concurrent.BlockingDeque<T>

Throws:

java.lang.InterruptedException

offerLast

public boolean offerLast(T t,
                         long timeout,
                         java.util.concurrent.TimeUnit unit)
                  throws java.lang.InterruptedException

Specified by:

offerLast in interface java.util.concurrent.BlockingDeque<T>

Throws:

java.lang.InterruptedException

takeFirst

@NotNull
public T takeFirst()
                      throws java.lang.InterruptedException

Specified by:

takeFirst in interface java.util.concurrent.BlockingDeque<T>

Throws:

java.lang.InterruptedException

takeLast

@NotNull
public T takeLast()
                     throws java.lang.InterruptedException

Specified by:

takeLast in interface java.util.concurrent.BlockingDeque<T>

Throws:

java.lang.InterruptedException

pollFirst

@Nullable
public T pollFirst(long timeout,
                              java.util.concurrent.TimeUnit unit)
                       throws java.lang.InterruptedException

Specified by:

pollFirst in interface java.util.concurrent.BlockingDeque<T>

Throws:

java.lang.InterruptedException

pollLast

@Nullable
public T pollLast(long timeout,
                             java.util.concurrent.TimeUnit unit)
                      throws java.lang.InterruptedException

Specified by:

pollLast in interface java.util.concurrent.BlockingDeque<T>

Throws:

java.lang.InterruptedException

removeFirstOccurrence

public boolean removeFirstOccurrence(@Nullable
                                     java.lang.Object o)

Specified by:

removeFirstOccurrence in interface java.util.concurrent.BlockingDeque<T>

Specified by:

removeFirstOccurrence in interface java.util.Deque<T>

removeLastOccurrence

public boolean removeLastOccurrence(@Nullable
                                    java.lang.Object o)

Specified by:

removeLastOccurrence in interface java.util.concurrent.BlockingDeque<T>

Specified by:

removeLastOccurrence in interface java.util.Deque<T>

add

public boolean add(T t)

Specified by:

add in interface java.util.Collection<T>

Specified by:

add in interface java.util.concurrent.BlockingDeque<T>

Specified by:

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

Specified by:

add in interface java.util.Deque<T>

Specified by:

add in interface java.util.Queue<T>

offer

public boolean offer(T t)

Specified by:

offer in interface java.util.concurrent.BlockingDeque<T>

Specified by:

offer in interface java.util.concurrent.BlockingQueue<T>

Specified by:

offer in interface java.util.Deque<T>

Specified by:

offer in interface java.util.Queue<T>

put

public void put(T t)
         throws java.lang.InterruptedException

Specified by:

put in interface java.util.concurrent.BlockingDeque<T>

Specified by:

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

Throws:

java.lang.InterruptedException

offer

public boolean offer(T t,
                     long timeout,
                     java.util.concurrent.TimeUnit unit)
              throws java.lang.InterruptedException

Specified by:

offer in interface java.util.concurrent.BlockingDeque<T>

Specified by:

offer in interface java.util.concurrent.BlockingQueue<T>

Throws:

java.lang.InterruptedException

remove

@NotNull
public T remove()

Specified by:

remove in interface java.util.concurrent.BlockingDeque<T>

Specified by:

remove in interface java.util.Deque<T>

Specified by:

remove in interface java.util.Queue<T>

poll

@Nullable
public T poll()

Specified by:

poll in interface java.util.concurrent.BlockingDeque<T>

Specified by:

poll in interface java.util.Deque<T>

Specified by:

poll in interface java.util.Queue<T>

take

@NotNull
public T take()
                 throws java.lang.InterruptedException

Specified by:

take in interface java.util.concurrent.BlockingDeque<T>

Specified by:

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

Throws:

java.lang.InterruptedException

poll

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

Specified by:

poll in interface java.util.concurrent.BlockingDeque<T>

Specified by:

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

Throws:

java.lang.InterruptedException

remainingCapacity

public int remainingCapacity()

Specified by:

remainingCapacity in interface java.util.concurrent.BlockingQueue<T>

element

@NotNull
public T element()

Specified by:

element in interface java.util.concurrent.BlockingDeque<T>

Specified by:

element in interface java.util.Deque<T>

Specified by:

element in interface java.util.Queue<T>

peek

@Nullable
public T peek()

Specified by:

peek in interface java.util.concurrent.BlockingDeque<T>

Specified by:

peek in interface java.util.Deque<T>

Specified by:

peek in interface java.util.Queue<T>

remove

public boolean remove(@Nullable
                      java.lang.Object o)

Specified by:

remove in interface java.util.Collection<T>

Specified by:

remove in interface java.util.concurrent.BlockingDeque<T>

Specified by:

remove in interface java.util.concurrent.BlockingQueue<T>

Specified by:

remove in interface java.util.Deque<T>

containsAll

public boolean containsAll(@NotNull
                           java.util.Collection<?> collection)

Specified by:

containsAll in interface java.util.Collection<T>

addAll

public boolean addAll(@NotNull
                      java.util.Collection<? extends T> collection)

Specified by:

addAll in interface java.util.Collection<T>

removeAll

public boolean removeAll(@NotNull
                         java.util.Collection<?> collection)

Specified by:

removeAll in interface java.util.Collection<T>

retainAll

public boolean retainAll(@NotNull
                         java.util.Collection<?> collection)

Specified by:

retainAll in interface java.util.Collection<T>

clear

public void clear()

Specified by:

clear in interface java.util.Collection<T>

contains

public boolean contains(java.lang.Object o)

Specified by:

contains in interface java.util.Collection<T>

Specified by:

contains in interface java.util.concurrent.BlockingDeque<T>

Specified by:

contains in interface java.util.concurrent.BlockingQueue<T>

Specified by:

contains in interface java.util.Deque<T>

drainTo

public int drainTo(@NotNull
                   java.util.Collection<? super T> collection)

Specified by:

drainTo in interface java.util.concurrent.BlockingQueue<T>

drainTo

public int drainTo(@NotNull
                   java.util.Collection<? super T> collection,
                   int maxElements)

Specified by:

drainTo in interface java.util.concurrent.BlockingQueue<T>

size

public int size()

Specified by:

size in interface java.util.Collection<T>

Specified by:

size in interface java.util.concurrent.BlockingDeque<T>

Specified by:

size in interface java.util.Deque<T>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface java.util.Collection<T>

iterator

@NotNull
public java.util.Iterator<T> iterator()

Specified by:

iterator in interface java.lang.Iterable<T>

Specified by:

iterator in interface java.util.Collection<T>

Specified by:

iterator in interface java.util.concurrent.BlockingDeque<T>

Specified by:

iterator in interface java.util.Deque<T>

toArray

@NotNull
public java.lang.Object[] toArray()

Specified by:

toArray in interface java.util.Collection<T>

toArray

@NotNull
public <U> U[] toArray(@NotNull
                                 U[] writeArray)

Specified by:

toArray in interface java.util.Collection<T>

descendingIterator

@NotNull
public java.util.Iterator<T> descendingIterator()

Specified by:

descendingIterator in interface java.util.Deque<T>

push

public void push(T t)

Specified by:

push in interface java.util.concurrent.BlockingDeque<T>

Specified by:

push in interface java.util.Deque<T>

pop

@NotNull
public T pop()

Specified by:

pop in interface java.util.Deque<T>