![]() |
BaltradDex
BALTRAD Data Exchange System
|
Classes | |
| class | FrameRejectedExecutionHandler |
Public Member Functions | |
| FramePublisher (int queueSize, int corePoolSize, int maxPoolSize) | |
| FramePublisher (int queueSize, int corePoolSize, int maxPoolSize, int keepAliveTime) | |
| void | addTask (Runnable task) |
| void | setThreadPoolExecutor (ThreadPoolExecutor executor) |
Implements ThreadPoolExecutor used to execute concurrent tasks.
|
inline |
Constructor
|
inline |
Constructor
| queueSize | The size of the queue to use for the thread pool executor. |
| corePoolSize | The core pool size of the thread pool, i.e., the number for threads that will always be available there. |
| maxPoolSize | The maximum pool size of the thread pool. Threads above the core pool size will be created up to this level when the number of tasks in the the thread pool queue reaches 'queueSize'. |
| keepAliveTime | The maximum time in seconds that excess idle threads in the pool will wait for new tasks before terminating. |
|
inline |
Adds and executes task.
| task | Task class implementing Runnable interface |
|
inline |
Sets the thread pool executor to use. Usable for testing purposes.
| executor | The thread pool executor |