Package 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	Description
private final Map<Thread,R>	resources

Constructor Summary

Constructors

Constructor	Description
ThreadLocalPool()

Method Summary

Modifier and Type	Method	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 Details

resources

private final Map<Thread,R> resources

Constructor Details

ThreadLocalPool

public ThreadLocalPool()

Method Details

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>