Package io.bhagat.server
Class Server.ServerThread
- java.lang.Object
-
- java.lang.Thread
-
- io.bhagat.server.Server.ServerThread
-
- All Implemented Interfaces:
java.lang.Runnable
- Enclosing class:
- Server
public class Server.ServerThread extends java.lang.Thread
-
-
Field Summary
Fields Modifier and Type Field Description private java.net.Socketconnectionprivate Server.ConnectionIndexconnectionIndexprivate java.io.ObjectInputStreaminputprivate java.io.ObjectOutputStreamoutputprivate java.lang.ObjectreadObjectprivate booleanstop
-
Constructor Summary
Constructors Constructor Description ServerThread(java.net.Socket socket, Server parentServer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()Server.ConnectionIndexgetConnectionIndex()java.lang.Objectread()voidrun()voidsend(java.lang.Object obj)voidsetConnectionIndex(Server.ConnectionIndex connectionIndex)private voidsetupStreams()-
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
-
-
-
-
Field Detail
-
connection
private java.net.Socket connection
-
output
private java.io.ObjectOutputStream output
-
input
private java.io.ObjectInputStream input
-
readObject
private java.lang.Object readObject
-
connectionIndex
private Server.ConnectionIndex connectionIndex
-
stop
private volatile boolean stop
-
-
Constructor Detail
-
ServerThread
public ServerThread(java.net.Socket socket, Server parentServer)
-
-
Method Detail
-
read
public java.lang.Object read()
-
run
public void run()
- Specified by:
runin interfacejava.lang.Runnable- Overrides:
runin classjava.lang.Thread
-
send
public void send(java.lang.Object obj)
-
close
public void close()
-
setupStreams
private void setupStreams()
-
getConnectionIndex
public Server.ConnectionIndex getConnectionIndex()
- Returns:
- the connectionIndex
-
setConnectionIndex
public void setConnectionIndex(Server.ConnectionIndex connectionIndex)
- Parameters:
connectionIndex- the connectionIndex to set
-
-