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_, stopped_
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, getShouldStop, isServing, setServerEventHandler, setServing, setShouldStop
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)