Package com.glitchybyte.glib.concurrent.workqueue

Class GSequentialWorkQueueTask<T>

java.lang.Object

com.glitchybyte.glib.concurrent.GTask

com.glitchybyte.glib.concurrent.workqueue.GWorkQueueTask<T>

com.glitchybyte.glib.concurrent.workqueue.GSequentialWorkQueueTask<T>

Type Parameters:

T - Type of work item.

All Implemented Interfaces:

GWorkQueue<T>, Runnable

public final class GSequentialWorkQueueTask<T>
extends GWorkQueueTask<T>

A task implementation of a {code GAsyncWorkQueue} that processes work items sequentially.

Nested Class Summary

Nested classes/interfaces inherited from interface com.glitchybyte.glib.concurrent.workqueue.GWorkQueue

GWorkQueue.Builder<T>

Field Summary

Fields inherited from class com.glitchybyte.glib.concurrent.workqueue.GWorkQueueTask

processor, workQueue

Constructor Summary

Constructors

Constructor	Description
GSequentialWorkQueueTask(String threadName, Consumer<T> processor)	Creates a sequential work queue task.

Method Summary

Modifier and Type	Method	Description
protected void	processWork()	This method processes each work item.

Methods inherited from class com.glitchybyte.glib.concurrent.workqueue.GWorkQueueTask

addWork, run

Methods inherited from class com.glitchybyte.glib.concurrent.GTask

awaitDone, getTaskRunner, getTaskThreadName, interrupt, isDone, setTaskRunner, started

Methods inherited from class java.lang.Object

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

Constructor Details

GSequentialWorkQueueTask

public GSequentialWorkQueueTask(String threadName,
 Consumer<T> processor)

Creates a sequential work queue task.

Parameters:

threadName - Thread name.

processor - Work item processor.

Method Details

processWork

protected void processWork()

Description copied from class: GWorkQueueTask

This method processes each work item.

Implementations MUST call workQueue.doWork.

Specified by:

processWork in class GWorkQueueTask<T>