public class DynamicBatch
extends java.lang.Object
Constructor and Description |
---|
DynamicBatch(int initialSize) |
DynamicBatch(int initialSize,
long minInitialHeap) |
Modifier and Type | Method and Description |
---|---|
boolean |
gcLimitsExceeded() |
JvmMonitor |
getJvmMonitor() |
boolean |
hasUnprocessedItems() |
void |
incrementCounter() |
boolean |
isWithinJvmLimits() |
java.util.List<java.lang.Integer> |
items() |
protected void |
manageUnprocessedItems() |
boolean |
memoryLimitsExceeded() |
java.util.List<java.lang.Integer> |
nextItems(java.util.Iterator<java.lang.Integer> itemIterator)
1.
|
void |
reduceSize(double by) |
void |
setMaxAllowedGcIncreases(int allowedGcIncreases) |
void |
setRequiredFreeHeap(double requiredFreeHeap) |
void |
setRequiredFreeHeap(long requiredFreeHeap) |
int |
size() |
public static final Logger logger
public DynamicBatch(int initialSize)
public DynamicBatch(int initialSize, long minInitialHeap) throws JvmLimitsException
JvmLimitsException
public void setRequiredFreeHeap(double requiredFreeHeap) throws JvmLimitsException
requiredFreeHeap
- JvmLimitsException
public void setRequiredFreeHeap(long requiredFreeHeap) throws JvmLimitsException
requiredFreeHeap
- JvmLimitsException
public void setMaxAllowedGcIncreases(int allowedGcIncreases)
allowedGcIncreases
- the amount of continuously observed increases of the gc timepublic int size()
public java.util.List<java.lang.Integer> items()
public boolean hasUnprocessedItems()
public java.util.List<java.lang.Integer> nextItems(java.util.Iterator<java.lang.Integer> itemIterator)
itemIterator
- public void incrementCounter()
public void reduceSize(double by)
protected void manageUnprocessedItems()
public boolean isWithinJvmLimits()
public boolean gcLimitsExceeded()
public boolean memoryLimitsExceeded()
public JvmMonitor getJvmMonitor()
Copyright © 2007-2020 EDIT. All Rights Reserved.