Class TaggedSocketChannel

java.lang.Object

java.lang.Thread

edu.jas.util.TaggedSocketChannel

All Implemented Interfaces:

Runnable

public class TaggedSocketChannel
extends Thread

TaggedSocketChannel provides a communication channel with message tags for Java objects using TCP/IP sockets.

Nested Class Summary

Nested classes/interfaces inherited from class Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicInteger	blockedCount	Blocked threads count.
private static final boolean	debug
private static final String	DONE	End message.
private boolean	isRunning	Flag if receiver is running.
private static final org.apache.logging.log4j.Logger	logger
protected final Map<Integer, BlockingQueue>	queues	Queues for each message tag.
protected final SocketChannel	sc	Underlying socket channel.

Fields inherited from class Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
TaggedSocketChannel(SocketChannel s)	Constructs a tagged socket channel on the given socket channel s.

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the channel.
SocketChannel	getSocket()	Get the SocketChannel
void	init()	thread initialization and start.
int	messages()	Number of messages.
Object	receive(Integer tag)	Receive an object.
void	run()	Run receive() in an infinite loop.
void	send(Integer tag, Object v)	Sends an object.
int	tagSize()	Number of tags.
void	terminate()	Terminate the TaggedSocketChannel.
String	toString()	To string.

Methods inherited from class 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, yield

Methods inherited from class Object

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

Field Details

logger

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

debug

private static final boolean debug

isRunning

private volatile boolean isRunning

Flag if receiver is running.

DONE

private static final String DONE

End message.

See Also:

• Constant Field Values

blockedCount

private final AtomicInteger blockedCount

Blocked threads count.

sc

protected final SocketChannel sc

Underlying socket channel.

queues

protected final Map<Integer, BlockingQueue> queues

Queues for each message tag.

Constructor Details

TaggedSocketChannel

public TaggedSocketChannel(SocketChannel s)

Constructs a tagged socket channel on the given socket channel s.

Parameters:

s - A socket channel object.

Method Details

init

public void init()

thread initialization and start.

getSocket

public SocketChannel getSocket()

Get the SocketChannel

send

public void send(Integer tag,
 Object v)
          throws IOException

Sends an object.

Parameters:

tag - message tag

v - object to send

Throws:

IOException

receive

public Object receive(Integer tag)
               throws InterruptedException,
IOException,
ClassNotFoundException

Receive an object.

Parameters:

tag - message tag

Returns:

object received

Throws:

InterruptedException

IOException

ClassNotFoundException

close

public void close()

Closes the channel.

toString

public String toString()

To string.

Overrides:

toString in class Thread

See Also:

• Thread.toString()

tagSize

public int tagSize()

Number of tags.

Returns:

size of key set.

messages

public int messages()

Number of messages.

Returns:

sum of all messages in queues.

run

public void run()

Run receive() in an infinite loop.

Specified by:

run in interface Runnable

Overrides:

run in class Thread

See Also:

• Thread.run()

terminate

public void terminate()

Terminate the TaggedSocketChannel.