Class TaskQueue

java.lang.Object

com.xpdustry.claj.server.util.TaskQueue

public class TaskQueue
extends Object

Taken from arc-lite.

A lock-less thread-safe allocation-free unbounded queue. Allocation is only done when growing.

Why? ... Because it's funny having an overkill thing XD.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	TaskQueue.Chunk

Field Summary

Fields

Modifier and Type	Field	Description
protected static int	CHUNK
protected TaskQueue.Chunk	consumer
protected final AtomicBoolean	draining
protected int	index
protected final AtomicReference<TaskQueue.Chunk>	producer
protected final AtomicInteger	size

Constructor Summary

Constructors

Constructor	Description
TaskQueue()

Method Summary

Modifier and Type	Method	Description
void	clear()
boolean	post(Runnable task)
void	run()
int	size()

Methods inherited from class Object

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

Field Details

CHUNK

protected static int CHUNK

producer

protected final AtomicReference<TaskQueue.Chunk> producer

consumer

protected TaskQueue.Chunk consumer

index

protected int index

size

protected final AtomicInteger size

draining

protected final AtomicBoolean draining

Constructor Details

TaskQueue

public TaskQueue()

Method Details

post

public boolean post(Runnable task)

Returns:

whether the queue was empty.

run

public void run()

size

public int size()

clear

public void clear()