org.alfresco.jlan.oncrpc

Class RpcRequestThreadPool

java.lang.Object

org.alfresco.jlan.oncrpc.RpcRequestThreadPool

public class RpcRequestThreadPool
extends Object

ONC/RPC Request Thread Pool Class

Processes RPC requests using a pool of worker threads.

Author:

gkspencer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	RpcRequestThreadPool.ThreadWorker Thread Worker Inner Class

Field Summary

Fields

Modifier and Type	Field and Description
static int	DefaultWorkerThreads
static int	MaximumWorkerThreads
static int	MinimumWorkerThreads

Constructor Summary

Constructors

Constructor and Description
RpcRequestThreadPool(String threadName, int poolSize, RpcProcessor rpcServer) Class constructor
RpcRequestThreadPool(String threadName, RpcProcessor rpcServer) Class constructor

Method Summary

Methods

Modifier and Type	Method and Description
int	getNumberOfRequests() Return the number of requests in the queue
static boolean	hasDebug() Check if debug output is enabled
void	queueRpcRequest(RpcPacket pkt) Queue an RPC request to the thread pool for processing
void	shutdownThreadPool() Shutdown the thread pool and release all resources

Methods inherited from class java.lang.Object

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

Field Detail

DefaultWorkerThreads

public static final int DefaultWorkerThreads

See Also:

Constant Field Values

MinimumWorkerThreads

public static final int MinimumWorkerThreads

See Also:

Constant Field Values

MaximumWorkerThreads

public static final int MaximumWorkerThreads

See Also:

Constant Field Values

Constructor Detail

RpcRequestThreadPool

public RpcRequestThreadPool(String threadName,
                    RpcProcessor rpcServer)

Class constructor

Parameters:

threadName - String

rpcServer - RpcProcessor

RpcRequestThreadPool

public RpcRequestThreadPool(String threadName,
                    int poolSize,
                    RpcProcessor rpcServer)

Class constructor

Parameters:

threadName - String

poolSize - int

rpcServer - RpcProcessor

Method Detail

hasDebug

public static final boolean hasDebug()

Check if debug output is enabled

Returns:

boolean

getNumberOfRequests

public final int getNumberOfRequests()

Return the number of requests in the queue

Returns:

int

queueRpcRequest

public final void queueRpcRequest(RpcPacket pkt)

Queue an RPC request to the thread pool for processing

Parameters:

pkt - RpcPacket

shutdownThreadPool

public void shutdownThreadPool()

Shutdown the thread pool and release all resources