Package edu.jas.gb

Class HybridReducerReceiverEC<C extends RingElem<C>>

  • Type Parameters:
    C - coefficient type
    All Implemented Interfaces:
    java.lang.Runnable

    class HybridReducerReceiverEC<C extends RingElem<C>>
    extends java.lang.Thread
    Distributed server receiving worker thread.
    • Nested Class Summary

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

        java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void run()
      Work loop.
      void terminate()
      Terminate.
      • Methods inherited from class java.lang.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 java.lang.Object

        equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    • Field Detail

      • logger

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

        private static final boolean debug
      • active

        private final java.util.concurrent.atomic.AtomicInteger active
      • goon

        private volatile boolean goon
      • pairTag

        public final java.lang.Integer pairTag
        Message tag for pairs.
      • resultTag

        public final java.lang.Integer resultTag
        Message tag for results.
      • ackTag

        public final java.lang.Integer ackTag
        Message tag for acknowledgments.
    • Constructor Detail

      • HybridReducerReceiverEC

        HybridReducerReceiverEC​(Terminator fin,
                                java.util.concurrent.atomic.AtomicInteger a,
                                TaggedSocketChannel pc,
                                DistHashTable<java.lang.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 Detail

      • run

        public void run()
        Work loop.
        Specified by:
        run in interface java.lang.Runnable
        Overrides:
        run in class java.lang.Thread
        See Also:
        Thread.run()
      • terminate

        public void terminate()
        Terminate.