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.apache.commons.logging.Log LOG

• callQueue

  private final CallQueue callQueue

• executorService

  private ExecutorService 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