Package org.apache.hadoop.hbase.thrift

Class TBoundedThreadPoolServer

java.lang.Object

org.apache.thrift.server.TServer

org.apache.hadoop.hbase.thrift.TBoundedThreadPoolServer

@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	Description
static class	TBoundedThreadPoolServer.Args
private final 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	Description
private final CallQueue	callQueue
static final int	DEFAULT_MAX_QUEUED_REQUESTS
static final int	DEFAULT_MAX_WORKER_THREADS
static final int	DEFAULT_MIN_WORKER_THREADS	This default core pool size should be enough for many test scenarios.
private static final int	DEFAULT_THREAD_KEEP_ALIVE_TIME_SEC
private ThreadPoolExecutor	executorService	Executor service for handling client connections
private static final org.slf4j.Logger	LOG
static final String	MAX_QUEUED_REQUESTS_CONF_KEY	The maximum number of pending connections waiting in the queue.
static final String	MAX_WORKER_THREADS_CONF_KEY	The maximum size of the thread pool.
static final String	MIN_WORKER_THREADS_CONF_KEY	The "core size" of the thread pool.
private static final String	QUEUE_FULL_MSG
private TBoundedThreadPoolServer.Args	serverOptions
private boolean	stopped	Flag for stopping the server
static final String	THREAD_KEEP_ALIVE_TIME_SEC_CONF_KEY	Default amount of time in seconds to keep a thread alive.
static final 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	Description
TBoundedThreadPoolServer(TBoundedThreadPoolServer.Args options, ThriftMetrics metrics)

Method Summary

Modifier and Type	Method	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 Details

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 Details

TBoundedThreadPoolServer

public TBoundedThreadPoolServer(TBoundedThreadPoolServer.Args options,
 ThriftMetrics metrics)

Method Details

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