public class THsHaServer extends TNonblockingServer
Modifier and Type | Class and Description |
---|---|
static class |
THsHaServer.Args |
TNonblockingServer.SelectAcceptThread
AbstractNonblockingServer.AbstractNonblockingServerArgs<T extends AbstractNonblockingServer.AbstractNonblockingServerArgs<T>>, AbstractNonblockingServer.AbstractSelectThread, AbstractNonblockingServer.AsyncFrameBuffer, AbstractNonblockingServer.FrameBuffer
TServer.AbstractServerArgs<T extends TServer.AbstractServerArgs<T>>
LOGGER
eventHandler_, inputProtocolFactory_, inputTransportFactory_, outputProtocolFactory_, outputTransportFactory_, processorFactory_, serverTransport_
Constructor and Description |
---|
THsHaServer(THsHaServer.Args args)
Create the server with the specified Args configuration
|
Modifier and Type | Method and 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.
|
isStopped, joinSelector, startThreads, stop
serve, startListening, stopListening
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)