public interface BppManagerMBean
Modifier and Type | Method and Description |
---|---|
void |
freeze()
Freeze worker.
|
String[] |
getFirstPageSources()
Inputs represented by the first enqueued page in
String format. |
long |
getInputCount()
Number of individual inputs read from the input source.
|
int |
getMaxQueueSize()
Current results queue size limit.
|
int |
getNonFinishedCount()
Non finished items in the queue.
|
long |
getOutputCount()
Number of reported results.
|
int |
getPageSize()
Current page size.
|
int |
getQueueSize()
Current size of the results queue.
|
boolean |
isFrozen()
Check frozen status.
|
void |
killAllAndFreeze()
Kill first page and freeze worker.
|
void |
killFirstPage()
Kill first page unconditionally.
|
void |
killFirstPageIfBlocking()
Kill first page only if all other pages are ready.
|
void |
setMaxQueueSize(int queueSize)
Set new max queue size parameter.
|
void |
setPageSize(int size)
Set new page size.
|
void |
unfreeze()
Unfreeze worker.
|
int getMaxQueueSize()
void setMaxQueueSize(int queueSize)
queueSize
- New queue sizeint getQueueSize()
int getNonFinishedCount()
int getPageSize()
Number of input items bundled into one page which is one execution unit.
void setPageSize(int size)
Note that new page size will be effective upon next enqueue operation. Pages in the results queue are not affected.
size
- New page size.long getInputCount()
This is the sum of ready and reported, ready and not reported and enqueued inputs.
long getOutputCount()
String[] getFirstPageSources()
String
format.
More precisely the page in the head of the results queue. This page might be ready and waiting for reporting, in progress or wait for execution.
void killFirstPageIfBlocking()
All the inputs will be reported as failures. If the first page was not blocking an exception is thrown.
IllegalStateException
- If the first page is done (see Future.isDone()
or at least one page in the
queue is not done.void killFirstPage()
If the first page is ready and waiting for reporting the results will be overriden with failure.
void killAllAndFreeze()
boolean isFrozen()
void freeze()
Note that frozen status implies that worker will prefer blocking when queue size limits otherwise would allow new task submission. New task submission is however possibly accepted in frozen status.
If the worker is already frozen do nothing.
void unfreeze()
If the worker is not frozen do nothing.