net.sf.jqql.net
Class Porter

java.lang.Object
  java.lang.Thread
      net.sf.jqql.net.Porter

All Implemented Interfaces:

Runnable

public final class Porter
extends Thread

Send RecvThread

Author:

notxx

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

protected Selector	selector port selector
protected boolean	shutdown Sign of whether thread is end

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Porter()
construct a Porter.

Method Summary

void	addDisposeRequest(IPort p) add release request
void	addDisposeRequest(IProxy p) add release request
void	register(IPort port) Register a port to porter
void	register(IPort port, int ops) Use appointed operate register channel
void	register(IProxy proxy) Register a port, use in porxy validate
void	run() constant running vindicate IPort object of all register pass several function which transfer them, parting live up to empty dispatcher queue/fill receive queue/vindicate queue.
void	shutdown() Cloes proter
void	wakeup() Wake up selector
void	wakeup(Object handler) Wake up selector and register this proxy

Methods inherited from class java.lang.Thread

activeCount, checkAccess, 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

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

Field Detail

shutdown

protected boolean shutdown

Sign of whether thread is end

selector

protected Selector selector

port selector

Constructor Detail

Porter

public Porter()

construct a Porter.

Method Detail

register

public void register(IPort port)
              throws ClosedChannelException

Register a port to porter

Parameters:

port - Iport implement

Throws:

ClosedChannelException - if register fail

register

public void register(IPort port,
                     int ops)
              throws ClosedChannelException

Use appointed operate register channel

Parameters:

port -

ops -

Throws:

ClosedChannelException

register

public void register(IProxy proxy)
              throws ClosedChannelException

Register a port, use in porxy validate

Parameters:

proxy - IPpoxy implement class

Throws:

ClosedChannelException - if register fail

run

public void run()

constant running vindicate IPort object of all register pass several function which transfer them, parting live up to empty dispatcher queue/fill receive queue/vindicate queue.

Specified by:

run in interface Runnable

Overrides:

run in class Thread

See Also:

IPort.send(ByteBuffer), IPort#receive(ByteBuffer), IPort#maintain()

addDisposeRequest

public void addDisposeRequest(IPort p)

add release request

Parameters:

p -

addDisposeRequest

public void addDisposeRequest(IProxy p)

add release request

Parameters:

p -

shutdown

public void shutdown()

Cloes proter

wakeup

public void wakeup()

Wake up selector

wakeup

public void wakeup(Object handler)

Wake up selector and register this proxy

Parameters:

proxy -