public class RpcRequestThreadPool
extends java.lang.Object
Processes RPC requests using a pool of worker threads.
Modifier and Type | Class and Description |
---|---|
protected class |
RpcRequestThreadPool.ThreadWorker
Thread Worker Inner Class
|
Modifier and Type | Field and Description |
---|---|
static int |
DefaultWorkerThreads |
static int |
MaximumWorkerThreads |
static int |
MinimumWorkerThreads |
Constructor and Description |
---|
RpcRequestThreadPool(java.lang.String threadName,
int poolSize,
RpcProcessor rpcServer)
Class constructor
|
RpcRequestThreadPool(java.lang.String threadName,
RpcProcessor rpcServer)
Class constructor
|
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
|
public static final int DefaultWorkerThreads
public static final int MinimumWorkerThreads
public static final int MaximumWorkerThreads
public RpcRequestThreadPool(java.lang.String threadName, RpcProcessor rpcServer)
threadName
- StringrpcServer
- RpcProcessorpublic RpcRequestThreadPool(java.lang.String threadName, int poolSize, RpcProcessor rpcServer)
threadName
- StringpoolSize
- intrpcServer
- RpcProcessorpublic static final boolean hasDebug()
public final int getNumberOfRequests()
public final void queueRpcRequest(RpcPacket pkt)
pkt
- RpcPacketpublic void shutdownThreadPool()
Copyright © 2005 - 2010 Alfresco Software, Inc. All Rights Reserved.