stormpot 3.1 · stormpot.BAllocThread

Field Summary

Modifier and Type	Field and Description
private volatile long	allocationCount
private final Reallocator<T>	allocator
private final boolean	backgroundExpirationEnabled
private final CountDownLatch	completionLatch
private long	consecutiveAllocationFailures
private final BlockingQueue<BSlot<T>>	dead
private final long	defaultDeadPollTimeout
private boolean	didAnythingLastIteration
private final RefillPile<T>	disregardPile
private final Expiration<? super T>	expiration
private volatile long	failedAllocationCount
private final PreciseLeakDetector	leakDetector
private final LinkedTransferQueue<BSlot<T>>	live
private final MetricsRecorder	metricsRecorder
private final RefillPile<T>	newAllocations
private final AtomicInteger	poisonedSlots
private final BSlot<T>	poisonPill
private volatile boolean	shutdown
private static final long	shutdownPauseNanos The amount of time, in nanoseconds, to wait for more work when the shutdown process has deallocated all the dead and live slots it could get its hands on, but there are still (claimed) slots left.
private int	size
private volatile int	targetSize

Constructor Summary

Access	Constructor and Description
pack-priv	BAllocThread(LinkedTransferQueue<BSlot<T>> live, RefillPile<T> disregardPile, RefillPile<T> newAllocations, PoolBuilder<T> builder, BSlot<T> poisonPill)

Method Summary

Modifier and Type	Method and Description
private void	alloc(BSlot<T> slot)
private void	backgroundExpirationCheck()
private long	computeDeadPollTimeout()
private void	continuouslyReplenishPool()
pack-priv long	countLeakedObjects()
private void	dealloc(BSlot<T> slot)
pack-priv long	getAllocationCount()
pack-priv long	getFailedAllocationCount()
pack-priv int	getTargetSize()
private void	increaseSizeByAllocating()
private void	incrementAllocationCounts(boolean success)
pack-priv void	offerDeadSlot(BSlot<T> slot)
private void	proactivelyHealPoison()
private void	publishSlot(BSlot<T> slot, boolean success, long now)
private void	realloc(BSlot<T> slot)
private void	reallocateDeadSlot(BSlot<T> slot)
private void	recordObjectLifetimeSample(long nanoseconds)
private void	reduceSizeByDeallocating(BSlot<T> slot)
private void	registerWithLeakDetector(BSlot<T> slot)
private void	replenishPool()
private void	resetSlot(BSlot<T> slot, long now)
public void	run() Implements java.lang.Runnable.run. Runs this operation.
pack-priv void	setTargetSize(int size)
pack-priv Completion	shutdown(Thread allocatorThread)
private void	shutPoolDown()
private void	unregisterWithLeakDetector(BSlot<T> slot)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

allocationCount	back to summary
private volatile long allocationCount

allocator	back to summary
private final Reallocator<T> allocator

backgroundExpirationEnabled	back to summary
private final boolean backgroundExpirationEnabled

completionLatch	back to summary
private final CountDownLatch completionLatch

consecutiveAllocationFailures	back to summary
private long consecutiveAllocationFailures

dead	back to summary
private final BlockingQueue<BSlot<T>> dead

defaultDeadPollTimeout	back to summary
private final long defaultDeadPollTimeout

didAnythingLastIteration	back to summary
private boolean didAnythingLastIteration

disregardPile	back to summary
private final RefillPile<T> disregardPile

expiration	back to summary
private final Expiration<? super T> expiration

failedAllocationCount	back to summary
private volatile long failedAllocationCount

leakDetector	back to summary
private final PreciseLeakDetector leakDetector

live	back to summary
private final LinkedTransferQueue<BSlot<T>> live

metricsRecorder	back to summary
private final MetricsRecorder metricsRecorder

newAllocations	back to summary
private final RefillPile<T> newAllocations

poisonedSlots	back to summary
private final AtomicInteger poisonedSlots

poisonPill	back to summary
private final BSlot<T> poisonPill

shutdown	back to summary
private volatile boolean shutdown

shutdownPauseNanos	back to summary
private static final long shutdownPauseNanos The amount of time, in nanoseconds, to wait for more work when the shutdown process has deallocated all the dead and live slots it could get its hands on, but there are still (claimed) slots left.

size	back to summary
private int size

targetSize	back to summary
private volatile int targetSize

Constructor Detail

BAllocThread	back to summary
pack-priv BAllocThread(LinkedTransferQueue<BSlot<T>> live, RefillPile<T> disregardPile, RefillPile<T> newAllocations, PoolBuilder<T> builder, BSlot<T> poisonPill)

Method Detail

alloc	back to summary
private void alloc(BSlot<T> slot)

backgroundExpirationCheck	back to summary
private void backgroundExpirationCheck()

computeDeadPollTimeout	back to summary
private long computeDeadPollTimeout()

continuouslyReplenishPool	back to summary
private void continuouslyReplenishPool()

countLeakedObjects	back to summary
pack-priv long countLeakedObjects()

dealloc	back to summary
private void dealloc(BSlot<T> slot)

getAllocationCount	back to summary
pack-priv long getAllocationCount()

getFailedAllocationCount	back to summary
pack-priv long getFailedAllocationCount()

getTargetSize	back to summary
pack-priv int getTargetSize()

increaseSizeByAllocating	back to summary
private void increaseSizeByAllocating()

incrementAllocationCounts	back to summary
private void incrementAllocationCounts(boolean success)

offerDeadSlot	back to summary
pack-priv void offerDeadSlot(BSlot<T> slot)

proactivelyHealPoison	back to summary
private void proactivelyHealPoison()

publishSlot	back to summary
private void publishSlot(BSlot<T> slot, boolean success, long now)

realloc	back to summary
private void realloc(BSlot<T> slot)

reallocateDeadSlot	back to summary
private void reallocateDeadSlot(BSlot<T> slot)

recordObjectLifetimeSample	back to summary
private void recordObjectLifetimeSample(long nanoseconds)

reduceSizeByDeallocating	back to summary
private void reduceSizeByDeallocating(BSlot<T> slot)

registerWithLeakDetector	back to summary
private void registerWithLeakDetector(BSlot<T> slot)

replenishPool	back to summary
private void replenishPool() throws InterruptedException

resetSlot	back to summary
private void resetSlot(BSlot<T> slot, long now)

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

setTargetSize	back to summary
pack-priv void setTargetSize(int size)

shutdown	back to summary
pack-priv Completion shutdown(Thread allocatorThread)

shutPoolDown	back to summary
private void shutPoolDown()

unregisterWithLeakDetector	back to summary
private void unregisterWithLeakDetector(BSlot<T> slot)

pack-priv final Class BAllocThread<T extends Poolable>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail