Module stormpot

Package stormpot.internal

Class RefillPile<T extends Poolable>

java.lang.Object

java.util.concurrent.atomic.AtomicReference<RefillSlot<T>>

stormpot.internal.RefillPile<T>

Type Parameters:

T - The concrete Poolable object type.

All Implemented Interfaces:

Serializable

public final class RefillPile<T extends Poolable>
extends AtomicReference<RefillSlot<T>>

A RefillPile can collect objects, in a concurrent and wait-free manner, before releasing them all to a queue.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
RefillPile(BlockingQueue<BSlot<T>> refillQueue)	Create a refill pile that will refill into the given queue.

Method Summary

Modifier and Type	Method	Description
BSlot<T>	pop()	Remove a slot from the pile, if there is any.
void	push(BSlot<T> slot)	Push the given slot onto the stack.
boolean	refill()	Refill the target queue with all the slots that have been pushed onto this stack.
String	toString()

Methods inherited from class java.util.concurrent.atomic.AtomicReference

accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

RefillPile

public RefillPile(BlockingQueue<BSlot<T>> refillQueue)

Create a refill pile that will refill into the given queue.

Parameters:

refillQueue - The queue to refill into.

Method Details

push

public void push(BSlot<T> slot)

Push the given slot onto the stack. This method is wait-free.

Parameters:

slot - The slot instance to be pushed onto the stack.

pop

public BSlot<T> pop()

Remove a slot from the pile, if there is any.

Returns:

A slot that was removed from the pile, or null if there were no slots to remove.

refill

public boolean refill()

Refill the target queue with all the slots that have been pushed onto this stack. This method atomically pops all elements from the stack at once, and then pushed onto the queue one by one.

Returns:

true if any slots has been offered to the queue, or false if there were no slots in the pile.

toString

public String toString()

Overrides:

toString in class AtomicReference<RefillSlot<T extends Poolable>>