Package com.glitchybyte.glib.concurrent.workqueue

Class GParallelWorkQueueTask<T>

java.lang.Object

com.glitchybyte.glib.concurrent.GTask

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

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

Type Parameters:

T - Type of work item.

All Implemented Interfaces:

GWorkQueue<T>, Runnable

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

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

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
GParallelWorkQueueTask(String threadName, Consumer<T> processor)	Creates a parallel 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

GParallelWorkQueueTask

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

Creates a parallel 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>