|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.aerospike.client.policy.ClientPolicy
com.aerospike.client.async.AsyncClientPolicy
public final class AsyncClientPolicy
Container object for client policy Command.
Field Summary | |
---|---|
MaxCommandAction |
asyncMaxCommandAction
How to handle cases when the asynchronous maximum number of concurrent connections have been reached. |
int |
asyncMaxCommands
Maximum number of concurrent asynchronous commands that are active at any point in time. |
int |
asyncSelectorThreads
Number of selector threads used to process asynchronous network events. |
int |
asyncSelectorTimeout
Maximum milliseconds to wait for an asynchronous network selector event. |
java.util.concurrent.ExecutorService |
asyncTaskThreadPool
Asynchronous socket read/user callback task thread pool. |
Fields inherited from class com.aerospike.client.policy.ClientPolicy |
---|
failIfNotConnected, maxSocketIdle, maxThreads, timeout |
Constructor Summary | |
---|---|
AsyncClientPolicy()
|
Method Summary |
---|
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public MaxCommandAction asyncMaxCommandAction
public int asyncMaxCommands
max open connections = asyncMaxCommands *
The maximum open connections should not exceed the total socket file descriptors available on the client machine. The socket file descriptors available can be determined by the following command:
ulimit -n
public int asyncSelectorTimeout
public int asyncSelectorThreads
public java.util.concurrent.ExecutorService asyncTaskThreadPool
Example: asyncTaskThreadPool = Executors.newCachedThreadPool();
Constructor Detail |
---|
public AsyncClientPolicy()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |