public class THsHaServer extends TNonblockingServer
Modifier and Type | Class | Description |
---|---|---|
static class |
THsHaServer.Args |
AbstractNonblockingServer.AbstractNonblockingServerArgs<T extends AbstractNonblockingServer.AbstractNonblockingServerArgs<T>>, AbstractNonblockingServer.AbstractSelectThread, AbstractNonblockingServer.AsyncFrameBuffer, AbstractNonblockingServer.FrameBuffer
TNonblockingServer.SelectAcceptThread
TServer.AbstractServerArgs<T extends TServer.AbstractServerArgs<T>>
LOGGER
eventHandler_, inputProtocolFactory_, inputTransportFactory_, outputProtocolFactory_, outputTransportFactory_, processorFactory_, serverTransport_
Constructor | Description |
---|---|
THsHaServer(THsHaServer.Args args) |
Create the server with the specified Args configuration
|
Modifier and Type | Method | Description |
---|---|---|
protected static java.util.concurrent.ExecutorService |
createInvokerPool(THsHaServer.Args options) |
Helper to create an invoker pool
|
protected java.lang.Runnable |
getRunnable(AbstractNonblockingServer.FrameBuffer frameBuffer) |
|
protected void |
gracefullyShutdownInvokerPool() |
|
protected boolean |
requestInvoke(AbstractNonblockingServer.FrameBuffer frameBuffer) |
We override the standard invoke method here to queue the invocation for
invoker service instead of immediately invoking.
|
protected void |
waitForShutdown() |
A method that will block until when threads handling the serving have been
shut down.
|
serve, startListening, stopListening
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
isStopped, joinSelector, startThreads, stop
getEventHandler, isServing, setServerEventHandler, setServing
public THsHaServer(THsHaServer.Args args)
protected void waitForShutdown()
AbstractNonblockingServer
waitForShutdown
in class TNonblockingServer
protected static java.util.concurrent.ExecutorService createInvokerPool(THsHaServer.Args options)
protected void gracefullyShutdownInvokerPool()
protected boolean requestInvoke(AbstractNonblockingServer.FrameBuffer frameBuffer)
requestInvoke
in class TNonblockingServer
protected java.lang.Runnable getRunnable(AbstractNonblockingServer.FrameBuffer frameBuffer)