java.lang.Runnable
, WorkerTask
DefaultTcpTransportMapping.ServerThread
public abstract class AbstractTcpServerThread extends java.lang.Object implements WorkerTask
Modifier and Type | Field | Description |
---|---|---|
protected java.util.LinkedList<ServerSocketEntry> |
pending |
|
protected java.nio.channels.Selector |
selector |
|
protected boolean |
stop |
|
protected TcpTransportMapping |
tcpTransportMapping |
Constructor | Description |
---|---|
AbstractTcpServerThread(TcpTransportMapping tcpTransportMapping) |
Modifier and Type | Method | Description |
---|---|---|
void |
close() |
|
protected void |
closeChannel(java.nio.channels.SelectableChannel channel) |
|
protected void |
connectChannel(java.nio.channels.SelectionKey sk,
TcpAddress incomingAddress) |
|
void |
interrupt() |
Interrupts this task.
|
void |
join() |
Waits until this task has been finished.
|
abstract void |
run() |
|
void |
terminate() |
The
WorkerPool might call this method to hint the active
WorkTask instance to complete execution as soon as possible. |
protected TcpAddress |
writeData(java.nio.channels.SelectionKey sk,
TcpAddress incomingAddress) |
protected TcpTransportMapping tcpTransportMapping
protected volatile boolean stop
protected java.nio.channels.Selector selector
protected java.util.LinkedList<ServerSocketEntry> pending
public AbstractTcpServerThread(TcpTransportMapping tcpTransportMapping) throws java.io.IOException
java.io.IOException
public abstract void run()
run
in interface java.lang.Runnable
protected void connectChannel(java.nio.channels.SelectionKey sk, TcpAddress incomingAddress)
protected TcpAddress writeData(java.nio.channels.SelectionKey sk, TcpAddress incomingAddress)
protected void closeChannel(java.nio.channels.SelectableChannel channel)
public void close()
public void terminate()
WorkerTask
WorkerPool
might call this method to hint the active
WorkTask
instance to complete execution as soon as possible.terminate
in interface WorkerTask
public void join()
WorkerTask
join
in interface WorkerTask
public void interrupt()
WorkerTask
interrupt
in interface WorkerTask
Thread.interrupt()
Copyright © 2018 SNMP4J.org. All rights reserved.