com.jenjinstudios.io.concurrency

Class ExecutionTask<T extends ExecutionContext>

java.lang.Object

com.jenjinstudios.io.concurrency.ExecutionTask<T>

All Implemented Interfaces:

java.lang.Runnable

public class ExecutionTask<T extends ExecutionContext>
extends java.lang.Object
implements java.lang.Runnable

Executes ExecutableMessage objects which have been read.

Constructor Summary

Constructors

Constructor and Description
ExecutionTask(MessageQueue<T> messageQueue, T executionContext, java.util.Collection<java.util.function.Consumer<T>> contextualTasks) Construct a new ExecuteTask that will execute messages from the given MessageQueue.

Method Summary

Modifier and Type	Method and Description
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutionTask

public ExecutionTask(MessageQueue<T> messageQueue,
                     T executionContext,
                     java.util.Collection<java.util.function.Consumer<T>> contextualTasks)

Construct a new ExecuteTask that will execute messages from the given MessageQueue.

Parameters:

messageQueue - The MessageQueue.

executionContext - The context in which messages should execute.

contextualTasks - Tasks which should be invoked in synchronous fashion with the execution context.

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable