org.apache.hadoop.hbase.util

Class PoolMap.RoundRobinPool<R>

java.lang.Object

java.util.concurrent.CopyOnWriteArrayList<R>

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

Type Parameters:

R - the type of the resource

All Implemented Interfaces:

Serializable, Cloneable, Iterable<R>, Collection<R>, List<R>, RandomAccess, PoolMap.Pool<R>

Enclosing class:

PoolMap<K,V>

static class PoolMap.RoundRobinPool<R>
extends CopyOnWriteArrayList<R>
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	nextResource

Constructor Summary

Constructors

Constructor and Description
RoundRobinPool(int maxSize)

Method Summary

Modifier and Type	Method and Description
R	get()
R	put(R resource)
Collection<R>	values()

Methods inherited from class java.util.concurrent.CopyOnWriteArrayList

add, add, addAll, addAll, addAllAbsent, addIfAbsent, clear, clone, contains, containsAll, equals, forEach, get, hashCode, indexOf, indexOf, isEmpty, iterator, lastIndexOf, lastIndexOf, listIterator, listIterator, remove, remove, removeAll, removeIf, replaceAll, retainAll, set, size, sort, spliterator, subList, toArray, toArray, toString

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.util.PoolMap.Pool

clear, remove, size

Methods inherited from interface java.util.Collection

parallelStream, stream

Field Detail

maxSize

private int maxSize

nextResource

private int nextResource

Constructor Detail

RoundRobinPool

public RoundRobinPool(int maxSize)

Method Detail

put

public R put(R resource)

Specified by:

put in interface PoolMap.Pool<R>

get

public R get()

Specified by:

get in interface PoolMap.Pool<R>

values

public Collection<R> values()

Specified by:

values in interface PoolMap.Pool<R>