org.apache.hadoop.hbase.util

Class PoolMap.RoundRobinPool<R>

java.lang.Object

org.apache.hadoop.hbase.util.PoolMap.RoundRobinPool<R>

Type Parameters:

R - the type of the resource

All Implemented Interfaces:

PoolMap.Pool<R>

Enclosing class:

PoolMap<K,V>

static class PoolMap.RoundRobinPool<R>
extends Object
implements PoolMap.Pool<R>

The RoundRobinPool represents a PoolMap.Pool, which stores its resources in an ArrayList. It load-balances access to its resources by returning a different resource every time a given key is looked up.

If maxSize is set to Integer.MAX_VALUE, then the size of the pool is unbounded. Otherwise, it caps the number of resources in this pool to the (non-zero positive) value specified in maxSize.

Field Summary

Fields

Modifier and Type	Field and Description
private int	maxSize
private int	nextIndex
private List<R>	resources

Constructor Summary

Constructors

Constructor and Description
RoundRobinPool(int maxSize)

Method Summary

Modifier and Type	Method and Description
void	clear()
R	getOrCreate(PoolMap.PoolResourceSupplier<R> supplier)
boolean	remove(R resource)
int	size()
Collection<R>	values()

Methods inherited from class java.lang.Object

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

Field Detail

resources

private final List<R> resources

maxSize

private final int maxSize

nextIndex

private int nextIndex

Constructor Detail

RoundRobinPool

public RoundRobinPool(int maxSize)

Method Detail

getOrCreate

public R getOrCreate(PoolMap.PoolResourceSupplier<R> supplier)
              throws IOException

Specified by:

getOrCreate in interface PoolMap.Pool<R>

Throws:

IOException

remove

public boolean remove(R resource)

Specified by:

remove in interface PoolMap.Pool<R>

clear

public void clear()

Specified by:

clear in interface PoolMap.Pool<R>

values

public Collection<R> values()

Specified by:

values in interface PoolMap.Pool<R>

size

public int size()

Specified by:

size in interface PoolMap.Pool<R>