org.apache.hadoop.hbase.thrift

Class TBoundedThreadPoolServer

java.lang.Object

org.apache.thrift.server.TServer

org.apache.hadoop.hbase.thrift.TBoundedThreadPoolServer

@InterfaceAudience.Private
public class TBoundedThreadPoolServer
extends org.apache.thrift.server.TServer

A bounded thread pool server customized for HBase.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TBoundedThreadPoolServer.Args
private class	TBoundedThreadPoolServer.ClientConnnection

Nested classes/interfaces inherited from class org.apache.thrift.server.TServer

org.apache.thrift.server.TServer.AbstractServerArgs<T extends org.apache.thrift.server.TServer.AbstractServerArgs<T>>

Field Summary

Fields

Modifier and Type	Field and Description
private CallQueue	callQueue
static int	DEFAULT_MAX_QUEUED_REQUESTS
static int	DEFAULT_MAX_WORKER_THREADS
static int	DEFAULT_MIN_WORKER_THREADS This default core pool size should be enough for many test scenarios.
private static int	DEFAULT_THREAD_KEEP_ALIVE_TIME_SEC
private ThreadPoolExecutor	executorService Executor service for handling client connections
private static org.slf4j.Logger	LOG
static String	MAX_QUEUED_REQUESTS_CONF_KEY The maximum number of pending connections waiting in the queue.
static String	MAX_WORKER_THREADS_CONF_KEY The maximum size of the thread pool.
static String	MIN_WORKER_THREADS_CONF_KEY The "core size" of the thread pool.
private static String	QUEUE_FULL_MSG
private TBoundedThreadPoolServer.Args	serverOptions
private boolean	stopped Flag for stopping the server
static String	THREAD_KEEP_ALIVE_TIME_SEC_CONF_KEY Default amount of time in seconds to keep a thread alive.
static int	TIME_TO_WAIT_AFTER_SHUTDOWN_MS Time to wait after interrupting all worker threads.

Fields inherited from class org.apache.thrift.server.TServer

eventHandler_, inputProtocolFactory_, inputTransportFactory_, outputProtocolFactory_, outputTransportFactory_, processorFactory_, serverTransport_, stopped_

Constructor Summary

Constructors

Constructor and Description
TBoundedThreadPoolServer(TBoundedThreadPoolServer.Args options, ThriftMetrics metrics)

Method Summary

Modifier and Type	Method and Description
void	serve()
private void	shutdownServer() Loop until ExecutorService.awaitTermination(long, java.util.concurrent.TimeUnit) finally does return without an interrupted exception.
void	stop()

Methods inherited from class org.apache.thrift.server.TServer

getEventHandler, getShouldStop, isServing, setServerEventHandler, setServing, setShouldStop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

QUEUE_FULL_MSG

private static final String QUEUE_FULL_MSG

See Also:

Constant Field Values

MIN_WORKER_THREADS_CONF_KEY

public static final String MIN_WORKER_THREADS_CONF_KEY

The "core size" of the thread pool. New threads are created on every connection until this many threads are created.

See Also:

Constant Field Values

DEFAULT_MIN_WORKER_THREADS

public static final int DEFAULT_MIN_WORKER_THREADS

This default core pool size should be enough for many test scenarios. We want to override this with a much larger number (e.g. at least 200) for a large-scale production setup.

See Also:

Constant Field Values

MAX_WORKER_THREADS_CONF_KEY

public static final String MAX_WORKER_THREADS_CONF_KEY

The maximum size of the thread pool. When the pending request queue overflows, new threads are created until their number reaches this number. After that, the server starts dropping connections.

See Also:

Constant Field Values

DEFAULT_MAX_WORKER_THREADS

public static final int DEFAULT_MAX_WORKER_THREADS

See Also:

Constant Field Values

MAX_QUEUED_REQUESTS_CONF_KEY

public static final String MAX_QUEUED_REQUESTS_CONF_KEY

The maximum number of pending connections waiting in the queue. If there are no idle threads in the pool, the server queues requests. Only when the queue overflows, new threads are added, up to hbase.thrift.maxQueuedRequests threads.

See Also:

Constant Field Values

DEFAULT_MAX_QUEUED_REQUESTS

public static final int DEFAULT_MAX_QUEUED_REQUESTS

See Also:

Constant Field Values

THREAD_KEEP_ALIVE_TIME_SEC_CONF_KEY

public static final String THREAD_KEEP_ALIVE_TIME_SEC_CONF_KEY

Default amount of time in seconds to keep a thread alive. Worker threads are stopped after being idle for this long.

See Also:

Constant Field Values

DEFAULT_THREAD_KEEP_ALIVE_TIME_SEC

private static final int DEFAULT_THREAD_KEEP_ALIVE_TIME_SEC

See Also:

Constant Field Values

TIME_TO_WAIT_AFTER_SHUTDOWN_MS

public static final int TIME_TO_WAIT_AFTER_SHUTDOWN_MS

Time to wait after interrupting all worker threads. This is after a clean shutdown has been attempted.

See Also:

Constant Field Values

LOG

private static final org.slf4j.Logger LOG

callQueue

private final CallQueue callQueue

executorService

private ThreadPoolExecutor executorService

Executor service for handling client connections

stopped

private volatile boolean stopped

Flag for stopping the server

serverOptions

private TBoundedThreadPoolServer.Args serverOptions

Constructor Detail

TBoundedThreadPoolServer

public TBoundedThreadPoolServer(TBoundedThreadPoolServer.Args options,
                                ThriftMetrics metrics)

Method Detail

serve

public void serve()

Specified by:

serve in class org.apache.thrift.server.TServer

shutdownServer

private void shutdownServer()

Loop until ExecutorService.awaitTermination(long, java.util.concurrent.TimeUnit) finally does return without an interrupted exception. If we don't do this, then we'll shut down prematurely. We want to let the executor service clear its task queue, closing client sockets appropriately.

stop

public void stop()

Overrides:

stop in class org.apache.thrift.server.TServer