io.servicetalk.transport.netty.internal

Class SequentialTaskQueue<T>

java.lang.Object

io.servicetalk.transport.netty.internal.SequentialTaskQueue<T>

Type Parameters:

T - Type of tasks executed by this queue.

public abstract class SequentialTaskQueue<T>
extends java.lang.Object

A task queue that executes asynchronous tasks sequentially. Since the tasks executed by this queue are potentially asynchronous, it is required for the tasks to call postTaskTermination() after they are done either successfully or with a failure.

Field Summary

Fields

Modifier and Type	Field and Description
static int	UNBOUNDED

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SequentialTaskQueue(int initialCapacity, int maxCapacity) New instance.

Method Summary

Modifier and Type	Method and Description
protected abstract void	execute(T toExecute) Executes the passed task and call postTaskTermination() when the task has finished execution, synchronously or asynchronously.
boolean	offerAndTryExecute(T task) Adds the passed task to this queue and triggers execution if there is no task currently executing.
void	postTaskTermination() Callback to inform this queue that one of the task executed by this queue has terminated either successfully or with a failure.

Methods inherited from class java.lang.Object

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

Field Detail

UNBOUNDED

public static final int UNBOUNDED

See Also:

Constant Field Values

Constructor Detail

SequentialTaskQueue

protected SequentialTaskQueue(int initialCapacity,
                              int maxCapacity)

New instance.

Parameters:

initialCapacity - Initial capacity for the queue.

maxCapacity - Optional maximum capacity. UNBOUNDED if the queue needs to be unbounded.

Method Detail

offerAndTryExecute

public boolean offerAndTryExecute(T task)

Adds the passed task to this queue and triggers execution if there is no task currently executing.

Parameters:

task - to execute.

Returns:

true if the task was successfully added to this queue.

postTaskTermination

public final void postTaskTermination()

Callback to inform this queue that one of the task executed by this queue has terminated either successfully or with a failure.

execute

protected abstract void execute(T toExecute)

Executes the passed task and call postTaskTermination() when the task has finished execution, synchronously or asynchronously.

Parameters:

toExecute - Task to execute.