org.apache.hive.common.util

Class FixedSizedObjectPool<T>

java.lang.Object

org.apache.hive.common.util.FixedSizedObjectPool<T>

All Implemented Interfaces:

org.apache.hadoop.hive.common.Pool<T>

public class FixedSizedObjectPool<T>
extends Object
implements org.apache.hadoop.hive.common.Pool<T>

Simple object pool of limited size. Implemented as a lock-free ring buffer; may fail to produce items if there are too many concurrent users.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hive.common.Pool

org.apache.hadoop.hive.common.Pool.PoolObjectHelper<T>

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
FixedSizedObjectPool(int size, org.apache.hadoop.hive.common.Pool.PoolObjectHelper<T> helper)
FixedSizedObjectPool(int size, org.apache.hadoop.hive.common.Pool.PoolObjectHelper<T> helper, boolean doTraceLog)

Method Summary

Modifier and Type	Method and Description
void	offer(T t)
int	size()
T	take()
boolean	tryOffer(T t)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

FixedSizedObjectPool

public FixedSizedObjectPool(int size,
                            org.apache.hadoop.hive.common.Pool.PoolObjectHelper<T> helper)

FixedSizedObjectPool

public FixedSizedObjectPool(int size,
                            org.apache.hadoop.hive.common.Pool.PoolObjectHelper<T> helper,
                            boolean doTraceLog)

Method Detail

take

public T take()

Specified by:

take in interface org.apache.hadoop.hive.common.Pool<T>

offer

public void offer(T t)

Specified by:

offer in interface org.apache.hadoop.hive.common.Pool<T>

size

public int size()

Specified by:

size in interface org.apache.hadoop.hive.common.Pool<T>

tryOffer

public boolean tryOffer(T t)