Package edu.jas.gb

Class HybridReducerReceiverMPJ<C extends edu.jas.structure.RingElem<C>>

  • Type Parameters:
    C - coefficient type
    All Implemented Interfaces:
    java.lang.Runnable
    class HybridReducerReceiverMPJ<C extends edu.jas.structure.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

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static int ackTag
      Message tag for acknowledgments.
      boolean debug  
      (package private) int rank  
      static int resultTag
      Message tag for results.

      • Fields inherited from class java.lang.Thread

        MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

    • Constructor Summary

      Constructors 
      Constructor Description
      HybridReducerReceiverMPJ​(int r, edu.jas.util.Terminator fin, java.util.concurrent.atomic.AtomicInteger a, MPJChannel pc, DistHashTableMPJ<java.lang.Integer,​edu.jas.poly.GenPolynomial<C>> dl, edu.jas.gb.PairList<C> L)
      Constructor.

    • 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, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • debug

        public final boolean debug

      • rank

        final int rank

      • resultTag

        public static final int resultTag
        Message tag for results.

      • ackTag

        public static final int ackTag
        Message tag for acknowledgments.

    • Constructor Detail

      • HybridReducerReceiverMPJ

        HybridReducerReceiverMPJ​(int r,
                         edu.jas.util.Terminator fin,
                         java.util.concurrent.atomic.AtomicInteger a,
                         MPJChannel pc,
                         DistHashTableMPJ<java.lang.Integer,​edu.jas.poly.GenPolynomial<C>> dl,
                         edu.jas.gb.PairList<C> L)
        Constructor.
        Parameters:
        r - MPJ rank of partner.
        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.