messageProcessor
Class MessageProcessorController.ReplyMixThread

java.lang.Object
  java.lang.Thread
      messageProcessor.MessageProcessorController.ReplyMixThread

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

MessageProcessorController

private final class MessageProcessorController.ReplyMixThread
extends java.lang.Thread

Thread, which coordinates the mixing process of replies. Can be instantiated several times, to increase mix performance on systems with several processing units.

Included functionality:

• taking (unprocessed) replies from InputOutputHandler
• encrypting replies
• passing (the now processed) replies to the OutputStrategy component.

See RequestMixThread for the thread coordinating requests.

Author:

Karl-Peter Fuchs

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

private Recoder

recoder The Recoder used to encrypt messages.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

private

MessageProcessorController.ReplyMixThread(Recoder recoder) Saves references on the bypassed object and calls start() .

Method Summary

void	run() Coordinates the mixing process of replies.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

recoder

private Recoder recoder

The Recoder used to encrypt messages.

Constructor Detail

MessageProcessorController.ReplyMixThread

private MessageProcessorController.ReplyMixThread(Recoder recoder)

Saves references on the bypassed object and calls start() .

Parameters:

recoder - The Recoder that shall be used to encrypt messages.

Method Detail

run

public void run()

Coordinates the mixing process of replies.

Included functionality:

• taking (unprocessed) replies from InputOutputHandler
• encrypting replies
• passing (the now processed) replies to the OutputStrategy component.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread