public class AsyncTaskScheduler extends AbstractAsyncServiceScheduler
AbstractAsyncServiceScheduler.AsyncServiceSchedulerStatus
Constructor and Description |
---|
AsyncTaskScheduler(AsyncServiceSchedulerResultsReceiver resultsReceiver,
int poolSize,
RestorePartitionOperatorFactory restoreOperatorFactory)
Constructs new AsyncTaskScheduler with given pool size.
|
AsyncTaskScheduler(AsyncServiceSchedulerResultsReceiver resultsReceiver,
int poolSize,
RestorePartitionOperatorFactory restoreOperatorFactory,
int requestQueueSize)
Constructs new AsyncTaskScheduler with given pool size.
|
AsyncTaskScheduler(AsyncServiceSchedulerResultsReceiver resultsReceiver,
RestorePartitionOperatorFactory restoreOperatorFactory,
int availableCores)
Constructs new AsyncTaskScheduler, calculating ideal pool size from number of available cores.
|
AsyncTaskScheduler(AsyncServiceSchedulerResultsReceiver resultsReceiver,
RestorePartitionOperatorFactory restoreOperatorFactory,
int availableCores,
int requestQueueSize)
Constructs new AsyncTaskScheduler, calculating ideal pool size from number of available cores.
|
Modifier and Type | Method and Description |
---|---|
boolean |
pause()
Pauses AsyncTaskScheduler.
|
boolean |
resume()
Resumes AsyncTaskScheduler.
|
boolean |
shutdown()
Shuts down the AsyncTaskScheduler, cleaning up resources.
|
boolean |
startUp()
Starts up the AsyncTaskScheduler, so it is ready to consume and process requests.
|
MessageStatusCode |
submitRequest(MessageRequest request)
Submits an
AsyncTaskRequest to AsyncTaskScheduler. |
getStatus
public AsyncTaskScheduler(AsyncServiceSchedulerResultsReceiver resultsReceiver, int poolSize, RestorePartitionOperatorFactory restoreOperatorFactory)
resultsReceiver
- subscriber to send responses topoolSize
- number of threads in the asyncTaskScheduler's thread poolrestoreOperatorFactory
- factory for generating RestorePartitionOperators
AsyncServiceSchedulerResultsReceiver.reportServiceSchedulerResponse(MessageResponse)
.public AsyncTaskScheduler(AsyncServiceSchedulerResultsReceiver resultsReceiver, int poolSize, RestorePartitionOperatorFactory restoreOperatorFactory, int requestQueueSize)
resultsReceiver
- subscriber to send responses topoolSize
- number of threads in the asyncTaskScheduler's thread poolrestoreOperatorFactory
- factory for generating RestorePartitionOperatorsrequestQueueSize
- maximum capacity of the request queue
AsyncServiceSchedulerResultsReceiver.reportServiceSchedulerResponse(MessageResponse)
.public AsyncTaskScheduler(AsyncServiceSchedulerResultsReceiver resultsReceiver, RestorePartitionOperatorFactory restoreOperatorFactory, int availableCores)
resultsReceiver
- subscriber to send responses torestoreOperatorFactory
- factory for generating RestorePartitionOperatorsavailableCores
- number of cores available to the AsyncTaskScheduler
AsyncServiceSchedulerResultsReceiver.reportServiceSchedulerResponse(MessageResponse)
.public AsyncTaskScheduler(AsyncServiceSchedulerResultsReceiver resultsReceiver, RestorePartitionOperatorFactory restoreOperatorFactory, int availableCores, int requestQueueSize)
resultsReceiver
- subscriber to send responses torestoreOperatorFactory
- factory for generating RestorePartitionOperatorsavailableCores
- number of cores available to the AsyncTaskSchedulerrequestQueueSize
- maximum capacity of the request queue
AsyncServiceSchedulerResultsReceiver.reportServiceSchedulerResponse(MessageResponse)
.public MessageStatusCode submitRequest(MessageRequest request)
AsyncTaskRequest
to AsyncTaskScheduler. Schedules request to be executed
asynchronously.submitRequest
in class AbstractAsyncServiceScheduler
request
- - the request to be scheduled.UnsupportedOperationException
- if request type is not a valid AsyncTaskRequest type
(valid type: RESTORE_FTPS, RECONCILE_FTPS, RESTORE_FTPS_FROM_SNAPSHOT)NullPointerException
- if request is nullpublic boolean startUp()
startUp
in class AbstractAsyncServiceScheduler
public boolean shutdown()
shutdown
in class AbstractAsyncServiceScheduler
public boolean pause()
pause
in class AbstractAsyncServiceScheduler
public boolean resume()
resume
in class AbstractAsyncServiceScheduler