class SAMHandlerPool extends Object
| Constructor and Description |
|---|
SAMHandlerPool()Create the pool |
| Modifier and Type | Method and Description |
|---|---|
(package private) int | getActiveCount()Number of worker threads actively processing a command. |
(package private) ThreadPoolExecutor | getConnectors()Thread pool for blocking STREAM CONNECT operations. |
(package private) int | getPoolSize()Current worker pool size (may include idle threads). |
(package private) int | getQueueSize()Number of commands waiting in the worker queue. |
(package private) int | getRegisteredCount()Number of handlers currently registered (connected) |
(package private) void | register(SAMv3Handler handler)Register a v3 handler with the pool. |
(package private) void | start()Start the selector thread. |
(package private) void | stop()Stop the pool, interrupt selector, wait for workers. |
(package private) void | unregister(SAMv3Handler handler)Remove a handler's socket from the pool. |
int getActiveCount()
ThreadPoolExecutor getConnectors()
int getPoolSize()
int getQueueSize()
int getRegisteredCount()
void register(SAMv3Handler handler)
handler - non-nullvoid start()
void stop()
void unregister(SAMv3Handler handler)
handler - non-null