reactor.alloc

Class PartitionedAllocator<T extends Recyclable>

java.lang.Object

reactor.alloc.PartitionedAllocator<T>

All Implemented Interfaces:

Allocator<T>

Direct Known Subclasses:

ThreadPartitionedAllocator

public abstract class PartitionedAllocator<T extends Recyclable>
extends java.lang.Object
implements Allocator<T>

An Allocator implementation that allocates a single object per thread, similar to a ThreadLocal but more efficient. Objects created here are never released.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PartitionedAllocator(Supplier<T> factory)

Method Summary

Modifier and Type	Method and Description
Reference<T>	allocate() Allocate an object from the internal pool.
java.util.List<Reference<T>>	allocateBatch(int size) Allocate a batch of objects all at once.
protected abstract long	nextPartitionId()
void	release(java.util.List<Reference<T>> batch) Efficiently release a batch of References all at once.

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionedAllocator

protected PartitionedAllocator(Supplier<T> factory)

Method Detail

allocate

public Reference<T> allocate()

Description copied from interface: Allocator

Allocate an object from the internal pool.

Specified by:

allocate in interface Allocator<T extends Recyclable>

Returns:

a Reference that can be retained and released.

allocateBatch

public java.util.List<Reference<T>> allocateBatch(int size)

Description copied from interface: Allocator

Allocate a batch of objects all at once.

Specified by:

allocateBatch in interface Allocator<T extends Recyclable>

Parameters:

size - the number of objects to allocate

Returns:

a List of References to the allocated objects

release

public void release(java.util.List<Reference<T>> batch)

Description copied from interface: Allocator

Efficiently release a batch of References all at once.

Specified by:

release in interface Allocator<T extends Recyclable>

Parameters:

batch - the references to release

nextPartitionId

protected abstract long nextPartitionId()