Class ChannelFactory

java.lang.Object

java.lang.Thread

edu.jas.util.ChannelFactory

All Implemented Interfaces:

Runnable

public class ChannelFactory
extends Thread

ChannelFactory implements a symmetric and non blocking way of setting up sockets on the client and server side. The constructor sets up a ServerSocket and accepts and stores any Socket creation requests from clients. The created Sockets can the be retrieved from the store without blocking. Refactored for java.util.concurrent.

See Also:

• SocketChannel

Nested Class Summary

Nested classes/interfaces inherited from class Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
private final BlockingQueue<SocketChannel>	buf	BoundedBuffer for sockets.
private static final boolean	debug
static final int	DEFAULT_PORT	default port of socket.
private static final org.apache.logging.log4j.Logger	logger
private final int	port	port of socket.
private ServerSocket	srv	local server socket.
private boolean	srvrun	is local server up and running.
private boolean	srvstart	is thread started.

Fields inherited from class Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ChannelFactory()	Constructs a ChannelFactory on the DEFAULT_PORT.
ChannelFactory(int p)	Constructs a ChannelFactory.

Method Summary

Modifier and Type	Method	Description
SocketChannel	getChannel()	Get a new socket channel from a server socket.
SocketChannel	getChannel(String h)	Get a new socket channel to a given host.
SocketChannel	getChannel(String h, int p)	Get a new socket channel to a given host.
void	init()	thread initialization and start.
void	run()	Run the servers accept() in an infinite loop.
void	terminate()	Terminate the Channel Factory
String	toString()	toString.

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

DEFAULT_PORT

public static final int DEFAULT_PORT

default port of socket.

See Also:

• Constant Field Values

port

private final int port

port of socket.

buf

private final BlockingQueue<SocketChannel> buf

BoundedBuffer for sockets.

srv

private volatile ServerSocket srv

local server socket.

srvrun

private volatile boolean srvrun

is local server up and running.

srvstart

private volatile boolean srvstart

is thread started.

Constructor Details

ChannelFactory

public ChannelFactory()

Constructs a ChannelFactory on the DEFAULT_PORT.

ChannelFactory

public ChannelFactory(int p)

Constructs a ChannelFactory.

Parameters:

p - port.

Method Details

toString

public String toString()

toString.

Overrides:

toString in class Thread

init

public void init()

thread initialization and start.

getChannel

public SocketChannel getChannel()
                         throws InterruptedException

Get a new socket channel from a server socket.

Throws:

InterruptedException

getChannel

public SocketChannel getChannel(String h)
                         throws IOException

Get a new socket channel to a given host.

Parameters:

h - hostname

Throws:

IOException

getChannel

public SocketChannel getChannel(String h,
 int p)
                         throws IOException

Get a new socket channel to a given host.

Parameters:

h - hostname

p - port

Throws:

IOException

run

public void run()

Run the servers accept() in an infinite loop.

Specified by:

run in interface Runnable

Overrides:

run in class Thread

terminate

public void terminate()

Terminate the Channel Factory