org.jacorb.util

Class SelectorManager

java.lang.Object

java.lang.Thread

org.jacorb.util.SelectorManager

All Implemented Interfaces:

Runnable

public class SelectorManager
extends Thread

Defines the entity which waits for I/O and time events to occur and dispatches notifications to the interested request callbacks. This is used primarily to manage asynchronous I/O using the NIO package but could be used to help orchestrate other sorts of asynch event handling in the future.

Author:

Ciju John <johnc@ociweb.com>

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
SelectorManager() Constructs a new Selector Manager.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	add(SelectorRequest request) Adds a new request entity to the requestor pool.
void	configure(Configuration configuration) Gives the SelectorManager an oportunity to configure itself.
void	halt() signals the run loop to terminate
int	poolSize(SelectorRequest.Type type) get the current buffer depth for the given type of request
void	remove(SelectorRequest request) Remove an existing request before it has expired
void	run() The thread function

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

Constructor Detail

SelectorManager

public SelectorManager()

Constructs a new Selector Manager. Typically called by the ORB

Method Detail

configure

public void configure(Configuration configuration)
               throws ConfigurationException

Gives the SelectorManager an oportunity to configure itself. Follows the pattern common to JacORB objects.

Throws:

ConfigurationException

run

public void run()

The thread function

Specified by:

run in interface Runnable

Overrides:

run in class Thread

halt

public void halt()

signals the run loop to terminate

poolSize

public int poolSize(SelectorRequest.Type type)

get the current buffer depth for the given type of request

Parameters:

type - the request type of interest

Returns:

the pool (or requestbuffer) size

remove

public void remove(SelectorRequest request)

Remove an existing request before it has expired

Parameters:

request - is the event to be removed from the pool

add

public boolean add(SelectorRequest request)

Adds a new request entity to the requestor pool.

Parameters:

request - is the event to be added to the pool

Returns:

true if the request was successfully added