Package edu.jas.util

Class DistributedListServer

  • All Implemented Interfaces:
    java.lang.Runnable
    public class DistributedListServer
extends java.lang.Thread
    Server for the distributed version of a list.

    • Nested Class Summary

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

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

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void init()
      thread initialization and start.
      static void main​(java.lang.String[] args)
      main.
      void run()
      main server method.
      int size()
      number of servers.
      void terminate()
      terminate all servers.

      • 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

      • servers

        protected java.util.List<Broadcaster> servers

      • goon

        private volatile boolean goon

      • mythread

        private volatile java.lang.Thread mythread

      • listElem

        private Counter listElem

      • theList

        protected final java.util.SortedMap<Counter,​java.lang.Object> theList

    • Constructor Detail

      • DistributedListServer

        public DistributedListServer()
        Constructs a new DistributedListServer.

      • DistributedListServer

        public DistributedListServer​(int port)
        DistributedListServer.
        Parameters:
        port - to run server on.

      • DistributedListServer

        public DistributedListServer​(ChannelFactory cf)
        DistributedListServer.
        Parameters:
        cf - ChannelFactory to use.

    • Method Detail

      • main

        public static void main​(java.lang.String[] args)
                 throws java.lang.InterruptedException
        main. Usage: DistributedListServer <port>
        Throws:
        java.lang.InterruptedException

      • init

        public void init()
        thread initialization and start.

      • run

        public void run()
        main server method.
        Specified by:
        run in interface java.lang.Runnable
        Overrides:
        run in class java.lang.Thread

      • terminate

        public void terminate()
        terminate all servers.

      • size

        public int size()
        number of servers.