main.java.com.djrapitops.plan.systems.queue

Class Queue<T>

java.lang.Object

main.java.com.djrapitops.plan.systems.queue.Queue<T>

Type Parameters:

T - Object this queue consumes

Direct Known Subclasses:

ProcessingQueue

public abstract class Queue<T>
extends Object

Abstract implementation of a Queue.

Author:

Rsl1122

Field Summary

Fields

Modifier and Type	Field and Description
protected BlockingQueue<T>	queue
protected Setup<T>	setup

Constructor Summary

Constructors

Constructor and Description
Queue(BlockingQueue<T> queue) Constructor, defines queue.

Method Summary

Modifier and Type	Method and Description
void	add(T object) Add a object to the queue, default implementation.
int	size() Get how many objects are in the queue.
void	stop() Stops all activity and clears the queue.
List<T>	stopAndReturnLeftovers() Used to stop the queue processing and get the unprocessed objects.

Methods inherited from class java.lang.Object

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

Field Detail

queue

protected final BlockingQueue<T> queue

setup

protected Setup<T> setup

Constructor Detail

Queue

public Queue(BlockingQueue<T> queue)

Constructor, defines queue.

Parameters:

queue - BlockingQueue to use for this queue.

Method Detail

add

public void add(T object)

Add a object to the queue, default implementation.

Parameters:

object - Object to add.

stopAndReturnLeftovers

public List<T> stopAndReturnLeftovers()

Used to stop the queue processing and get the unprocessed objects.

Returns:

List of unprocessed objects.

stop

public void stop()

Stops all activity and clears the queue.

size

public int size()

Get how many objects are in the queue.

Returns:

size of the queue.