io.druid.collections

Class BlockingPool<T>

java.lang.Object

io.druid.collections.BlockingPool<T>

public class BlockingPool<T>
extends Object

Pool that pre-generates objects up to a limit, then permits possibly-blocking "take" operations.

Constructor Summary

Constructors

Constructor and Description
BlockingPool(com.google.common.base.Supplier<T> generator, int limit)

Method Summary

Modifier and Type	Method and Description
int	getPoolSize()
int	maxSize()
ReferenceCountingResourceHolder<T>	take(long timeout) Take a resource from the pool.
ReferenceCountingResourceHolder<List<T>>	takeBatch(int elementNum, long timeout) Take a resource from the pool.

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockingPool

public BlockingPool(com.google.common.base.Supplier<T> generator,
                    int limit)

Method Detail

maxSize

public int maxSize()

getPoolSize

public int getPoolSize()

take

public ReferenceCountingResourceHolder<T> take(long timeout)

Take a resource from the pool.

Parameters:

timeout - maximum time to wait for a resource, in milliseconds. Negative means do not use a timeout.

Returns:

a resource, or null if the timeout was reached

takeBatch

public ReferenceCountingResourceHolder<List<T>> takeBatch(int elementNum,
                                                          long timeout)

Take a resource from the pool.

Parameters:

elementNum - number of resources to take

timeout - maximum time to wait for resources, in milliseconds. Negative means do not use a timeout.

Returns:

a resource, or null if the timeout was reached