| Package | Description |
|---|---|
| com.pushtechnology.diffusion.api.publisher |
Diffusion Internal Publisher API.
|
| com.pushtechnology.diffusion.api.threads |
Diffusion Threads and Concurrency API.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
Publishers.addEventListener(ServerEventListener listener,
ThreadPool threadPool,
int notificationMask)
Add an event listener.
|
| Modifier and Type | Method and Description |
|---|---|
static ThreadPool |
ThreadService.createThreadPool(String name,
int coreSize,
int maxSize,
int queueSize,
int priority)
Creates a new thread pool.
|
static ThreadPool |
ThreadService.getBackgroundThreadPool()
Returns the background thread pool.
|
static ThreadPool |
ThreadService.getThreadPool(String poolName)
Returns a named thread pool.
|
| Modifier and Type | Method and Description |
|---|---|
static List<ThreadPool> |
ThreadService.getThreadPools()
Returns the full list of currently defined thread pools.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ThreadPoolNotificationHandler.queueLowerThresholdReached(ThreadPool pool)
This is called when a configured lower threshold for a thread pool
queue has been reached.
|
void |
ThreadPoolNotificationHandler.queueUpperThresholdReached(ThreadPool pool)
This is called when a configured upper threshold for a thread pool
queue has been reached.
|
void |
ThreadService.CallerRunsRejectionPolicy.rejectedExecution(RunnableTask runnable,
ThreadPool threadPool) |
void |
ThreadService.AbortRejectionPolicy.rejectedExecution(RunnableTask runnable,
ThreadPool threadPool) |
void |
ThreadPoolRejectionHandler.rejectedExecution(RunnableTask runnable,
ThreadPool threadPool)
Called when a task can not be executed by a
ThreadPool. |
void |
ThreadPoolNotificationHandler.rejectedExecution(ThreadPool pool)
Notifies rejection of execution of a runnable by the pool.
|
Copyright © 2019 Push Technology Ltd. All Rights Reserved.