Class ClientThread

java.lang.Object

java.lang.Thread

net.sf.colossus.client.ClientThread

All Implemented Interfaces:

Runnable

public class ClientThread
extends Thread

This will be a thread that executes all the client side processing; additional to the actual SocketClientThread which did that earlier. SCT will only handle the reading from Socket and push incoming messages to a queue and return back to listening on the socket. This way, it should be able to read all data in time so that no data pile up, and reply to ping requests almost instantly. ClientThread gets most of messages to parse already via a queue. Should also sending use a queue, and/or, the sending methods be inside ClientThread, and SocketClientThread merely provide the sendToServer method (which could be implemented differently e.g. in a "send via queue, instead of via socket", for local clients)?

Author:

Clemens Katzer

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ClientThread.ServerEvent

Nested classes/interfaces inherited from class Thread

Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
private final Client	client
private boolean	done
private static final ClientThread.ServerEvent	END_EVENT
private final boolean	LOG_PROCESSING_TIMES
private static final Logger	LOGGER
private final LinkedBlockingQueue<ClientThread.ServerEvent>	queue
private final int	threadNr
private static int	threadNumberCounter

Fields inherited from class Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ClientThread(Client client)

Method Summary

Modifier and Type	Method	Description
void	appendToConnectionLog(String s)
private void	callMethod(String method, List<String> args)
void	disposeClient()
void	disposeQueue()
void	enqueue(String method, List<String> args)
String	getNameMaybe()
static long	getNow()
int	getQueueLen()
int	getThreadNumber()
private static int	nextThreadNumber()
void	notifyThatNotConnected()
void	notifyUserIfGameIsPaused(String message)
private BattleHex	resolveBattleHex(String hexLabel)
private CreatureType	resolveCreatureType(String creatureName)
private List<CreatureType>	resolveCreatureTypes(String nameList)
private MasterHex	resolveHex(String label)
private Legion	resolveLegion(String markerId)
void	run()
void	setClosedByServer()

Methods inherited from class Thread

activeCount, checkAccess, clone, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, start, startVirtualThread, stop, threadId, toString, yield

Methods inherited from class Object

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

Field Details

LOGGER

private static final Logger LOGGER

threadNumberCounter

private static int threadNumberCounter

threadNr

private final int threadNr

client

private final Client client

queue

private final LinkedBlockingQueue<ClientThread.ServerEvent> queue

done

private boolean done

LOG_PROCESSING_TIMES

private final boolean LOG_PROCESSING_TIMES

See Also:

• Constant Field Values

END_EVENT

private static final ClientThread.ServerEvent END_EVENT

Constructor Details

ClientThread

public ClientThread(Client client)

Method Details

nextThreadNumber

private static int nextThreadNumber()

getThreadNumber

public int getThreadNumber()

enqueue

public void enqueue(String method,
 List<String> args)

getQueueLen

public int getQueueLen()

disposeQueue

public void disposeQueue()

disposeClient

public void disposeClient()

setClosedByServer

public void setClosedByServer()

getNameMaybe

public String getNameMaybe()

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

notifyUserIfGameIsPaused

public void notifyUserIfGameIsPaused(String message)

notifyThatNotConnected

public void notifyThatNotConnected()

appendToConnectionLog

public void appendToConnectionLog(String s)

callMethod

private void callMethod(String method,
 List<String> args)

resolveHex

private MasterHex resolveHex(String label)

resolveBattleHex

private BattleHex resolveBattleHex(String hexLabel)

resolveCreatureTypes

private List<CreatureType> resolveCreatureTypes(String nameList)

resolveCreatureType

private CreatureType resolveCreatureType(String creatureName)

resolveLegion

private Legion resolveLegion(String markerId)

getNow

public static long getNow()