Modifier and Type	Class and Description
private static class	PooledBlockAllocatorProvider.PooledBlockAllocator A `BlockAllocator` of for a particular size that has a single thread-safe free list.

Modifier and Type	Field and Description
private final ConcurrentMap<Integer, BlockAllocator>	allocators
private static final PooledBlockAllocatorProvider	INSTANCE

Access	Constructor and Description
private	PooledBlockAllocatorProvider()

Modifier and Type	Method and Description
public static PooledBlockAllocatorProvider	getInstance()
public BlockAllocator	vendAllocator(final int blockSize) Implements abstract com.amazon.ion.impl.bin.BlockAllocatorProvider.vendAllocator. Returns a `BlockAllocator` that vends blocks of the given size.

allocators	back to summary
private final ConcurrentMap<Integer, BlockAllocator> allocators

INSTANCE	back to summary
private static final PooledBlockAllocatorProvider INSTANCE

PooledBlockAllocatorProvider	back to summary
private PooledBlockAllocatorProvider()

Method Detail

getInstance	back to summary
public static PooledBlockAllocatorProvider getInstance()

vendAllocator back to summary

vendAllocator	back to summary
public BlockAllocator vendAllocator(final int blockSize) Implements abstract com.amazon.ion.impl.bin.BlockAllocatorProvider.vendAllocator. Doc from com.amazon.ion.impl.bin.BlockAllocatorProvider.vendAllocator. Returns a `BlockAllocator` that vends blocks of the given size. This method can be used across threads, but the returned `BlockAllocator` instances are not thread-safe and must have their `BlockAllocator#close()` method called to allow its underlying resources to be released or reused properly. Annotations @Override

public BlockAllocator vendAllocator(final int blockSize)

Implements abstract com.amazon.ion.impl.bin.BlockAllocatorProvider.vendAllocator.

Doc from com.amazon.ion.impl.bin.BlockAllocatorProvider.vendAllocator.

Returns a BlockAllocator that vends blocks of the given size. This method can be used across threads, but the returned BlockAllocator instances are not thread-safe and must have their BlockAllocator#close() method called to allow its underlying resources to be released or reused properly.

Annotations

@Override

com.amazon.ion.impl.bin back to summary

private final Class PooledBlockAllocatorProvider.PooledBlockAllocator

Class Inheritance

extends BlockAllocator

java.lang.Object
com.amazon.ion.impl.bin.BlockAllocator
com.amazon.ion.impl.bin.PooledBlockAllocatorProvider.PooledBlockAllocator

A BlockAllocator of for a particular size that has a single thread-safe free list.

This implementation is thread-safe.

Field Summary

Modifier and Type	Field and Description
private final int	blockLimit
private final int	blockSize
pack-priv static final int	FREE_CAPACITY
private final ConcurrentLinkedQueue<Block>	freeBlocks
private final AtomicInteger	size

Constructor Summary

Access	Constructor and Description
public	PooledBlockAllocator(final int blockSize)

Method Summary

Modifier and Type	Method and Description
public Block	allocateBlock() Implements abstract com.amazon.ion.impl.bin.BlockAllocator.allocateBlock. Allocates a `Block` instance to the caller.
public void	close() Implements abstract com.amazon.ion.impl.bin.BlockAllocator.close. Implements java.io.Closeable.close. Releases the allocator back to the `BlockAllocatorProvider` from whence it came.
public int	getBlockSize() Implements abstract com.amazon.ion.impl.bin.BlockAllocator.getBlockSize. Returns the fixed block size of the allocator.

Field Detail

blockLimit	back to summary
private final int blockLimit

blockSize	back to summary
private final int blockSize

FREE_CAPACITY	back to summary
pack-priv static final int FREE_CAPACITY

freeBlocks	back to summary
private final ConcurrentLinkedQueue<Block> freeBlocks

size	back to summary
private final AtomicInteger size

Constructor Detail

PooledBlockAllocator	back to summary
public PooledBlockAllocator(final int blockSize)

Method Detail

allocateBlock back to summary

allocateBlock	back to summary
public Block allocateBlock() Implements abstract com.amazon.ion.impl.bin.BlockAllocator.allocateBlock. Doc from com.amazon.ion.impl.bin.BlockAllocator.allocateBlock. Allocates a `Block` instance to the caller. The caller owns the block until `Block#close()` is called--once `Block#close()` is called, an implementation may re-allocate it to another caller. Annotations @Override

public Block allocateBlock()

Implements abstract com.amazon.ion.impl.bin.BlockAllocator.allocateBlock.

Doc from com.amazon.ion.impl.bin.BlockAllocator.allocateBlock.

Allocates a Block instance to the caller. The caller owns the block until Block#close() is called--once Block#close() is called, an implementation may re-allocate it to another caller.

Annotations

@Override

close back to summary

close	back to summary
public void close() Implements abstract com.amazon.ion.impl.bin.BlockAllocator.close. Implements java.io.Closeable.close. Doc from com.amazon.ion.impl.bin.BlockAllocator.close. Releases the allocator back to the `BlockAllocatorProvider` from whence it came. This is used to allow underlying resources to be reclaimed and/or released properly. Annotations @Override

public void close()

Implements abstract com.amazon.ion.impl.bin.BlockAllocator.close.

Implements java.io.Closeable.close.

Doc from com.amazon.ion.impl.bin.BlockAllocator.close.

Releases the allocator back to the BlockAllocatorProvider from whence it came. This is used to allow underlying resources to be reclaimed and/or released properly.

Annotations

@Override

getBlockSize	back to summary
public int getBlockSize() Implements abstract com.amazon.ion.impl.bin.BlockAllocator.getBlockSize. Doc from com.amazon.ion.impl.bin.BlockAllocator.getBlockSize. Returns the fixed block size of the allocator. Annotations @Override

getBlockSize

back to summary

public int getBlockSize()

Implements abstract com.amazon.ion.impl.bin.BlockAllocator.getBlockSize.

Doc from com.amazon.ion.impl.bin.BlockAllocator.getBlockSize.

Returns the fixed block size of the allocator.

Annotations