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

Class Consumer<T>

java.lang.Object

com.djrapitops.plugin.task.AbsRunnable

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

Type Parameters:

T -

public abstract class Consumer<T>
extends com.djrapitops.plugin.task.AbsRunnable

Abstract class representing a queue consumer.

Author:

Rsl1122

Field Summary

Fields

Modifier and Type	Field and Description
protected BlockingQueue<T>	queue
protected boolean	run

Constructor Summary

Constructors

Constructor and Description
Consumer(BlockingQueue<T> queue, String name) Constructor, defines queue.

Method Summary

Modifier and Type	Method and Description
protected abstract void	clearVariables()
protected abstract void	consume(T toConsume)
void	run()
protected void	stop()

Methods inherited from class com.djrapitops.plugin.task.AbsRunnable

cancel, getName, getTaskId, getTaskName, setCancellable

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

run

protected boolean run

Constructor Detail

Consumer

public Consumer(BlockingQueue<T> queue,
                String name)

Constructor, defines queue.

Parameters:

queue - Queue to consume from.

name - Name of the queue.

Method Detail

run

public void run()

Specified by:

run in class com.djrapitops.plugin.task.AbsRunnable

stop

protected void stop()

clearVariables

protected abstract void clearVariables()

consume

protected abstract void consume(T toConsume)