Class HybridReducerReceiverEC<C extends RingElem<C>>

java.lang.Object

java.lang.Thread

edu.jas.gb.HybridReducerReceiverEC<C>

Type Parameters:

C - coefficient type

All Implemented Interfaces:

Runnable

class HybridReducerReceiverEC<C extends RingElem<C>>
extends Thread

Distributed server receiving worker thread.

Nested Class Summary

Nested classes/interfaces inherited from class Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
final Integer	ackTag	Message tag for acknowledgments.
private final AtomicInteger	active
private static final boolean	debug
private final Terminator	finner
private boolean	goon
private static final org.apache.logging.log4j.Logger	logger
private final TaggedSocketChannel	pairChannel
private final PairList<C>	pairlist
final Integer	pairTag	Message tag for pairs.
final Integer	resultTag	Message tag for results.
private final DistHashTable<Integer, GenPolynomial<C>>	theList

Fields inherited from class Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
HybridReducerReceiverEC(Terminator fin, AtomicInteger a, TaggedSocketChannel pc, DistHashTable<Integer, GenPolynomial<C>> dl, PairList<C> L)	Constructor.

Method Summary

Modifier and Type	Method	Description
void	run()	Work loop.
void	terminate()	Terminate.

Methods inherited from class Thread

activeCount, checkAccess, clone, 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 Object

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

Field Details

logger

private static final org.apache.logging.log4j.Logger logger

debug

private static final boolean debug

theList

private final DistHashTable<Integer, GenPolynomial<C extends RingElem<C>>> theList

pairlist

private final PairList<C extends RingElem<C>> pairlist

pairChannel

private final TaggedSocketChannel pairChannel

finner

private final Terminator finner

active

private final AtomicInteger active

goon

private volatile boolean goon

pairTag

public final Integer pairTag

Message tag for pairs.

resultTag

public final Integer resultTag

Message tag for results.

ackTag

public final Integer ackTag

Message tag for acknowledgments.

Constructor Details

HybridReducerReceiverEC

HybridReducerReceiverEC(Terminator fin,
 AtomicInteger a,
 TaggedSocketChannel pc,
 DistHashTable<Integer, GenPolynomial<C>> dl,
 PairList<C> L)

Constructor.

Parameters:

fin - terminator

a - active remote tasks count

pc - tagged socket channel

dl - distributed hash table

L - ordered pair list

Method Details

run

public void run()

Work loop.

Specified by:

run in interface Runnable

Overrides:

run in class Thread

See Also:

• Thread.run()

terminate

public void terminate()

Terminate.