org.apache.hadoop.hbase.util

Class PoolMap.ThreadLocalPool<R>

java.lang.Object

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

Type Parameters:

R - the type of the resource

All Implemented Interfaces:

PoolMap.Pool<R>

Enclosing class:

PoolMap<K,V>

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

The ThreadLocalPool represents a PoolMap.Pool that works similarly to ThreadLocal class. It essentially binds the resource to the thread from which it is accessed. It doesn't remove resources when a thread exits, those resources must be closed manually.

Note that the size of the pool is essentially bounded by the number of threads that add resources to this pool.

Field Summary

Fields

Modifier and Type	Field and Description
private Map<Thread,R>	resources

Constructor Summary

Constructors

Constructor and Description
ThreadLocalPool()

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 Map<Thread,R> resources

Constructor Detail

ThreadLocalPool

public ThreadLocalPool()

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>

size

public int size()

Specified by:

size 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>