com.jenjinstudios.io.concurrency

Class WriteTask<T extends ExecutionContext>

java.lang.Object

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

All Implemented Interfaces:

java.lang.Runnable

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

Writes messages from the outgoing list in the MessageQueue.

Constructor Summary

Constructors

Constructor and Description
WriteTask(MessageQueue<T> messageQueue, MessageWriter messageWriter) Construct a new WriteTask that will send messages from the given MessageQueue via the given MessageWriter.

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

WriteTask

public WriteTask(MessageQueue<T> messageQueue,
                 MessageWriter messageWriter)

Construct a new WriteTask that will send messages from the given MessageQueue via the given MessageWriter.

Parameters:

messageQueue - The MessageQueue.

messageWriter - The MessageWriter.

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable