org.apache.thrift.server
Class THsHaServer
java.lang.Object
org.apache.thrift.server.TServer
org.apache.thrift.server.TNonblockingServer
org.apache.thrift.server.THsHaServer
public class THsHaServer
- extends TNonblockingServer
An extension of the TNonblockingServer to a Half-Sync/Half-Async server.
Like TNonblockingServer, it relies on the use of TFramedTransport.
Constructor Summary |
THsHaServer(THsHaServer.Args args)
Create server with every option fully specified, and with an injected
ExecutorService |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
THsHaServer
public THsHaServer(THsHaServer.Args args)
- Create server with every option fully specified, and with an injected
ExecutorService
serve
public void serve()
- Description copied from class:
TNonblockingServer
- Begin accepting connections and processing invocations.
- Overrides:
serve
in class TNonblockingServer
createInvokerPool
protected static java.util.concurrent.ExecutorService createInvokerPool(THsHaServer.Args options)
- Helper to create an invoker pool
gracefullyShutdownInvokerPool
protected void gracefullyShutdownInvokerPool()
requestInvoke
protected boolean requestInvoke(TNonblockingServer.FrameBuffer frameBuffer)
- We override the standard invoke method here to queue the invocation for
invoker service instead of immediately invoking. The thread pool takes care of the rest.
- Overrides:
requestInvoke
in class TNonblockingServer
getRunnable
protected java.lang.Runnable getRunnable(TNonblockingServer.FrameBuffer frameBuffer)