io.druid.collections

Class DefaultBlockingPool<T>

java.lang.Object

io.druid.collections.DefaultBlockingPool<T>

All Implemented Interfaces:

BlockingPool<T>

public class DefaultBlockingPool<T>
extends Object
implements BlockingPool<T>

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
int	getPoolSize()
int	maxSize()
ReferenceCountingResourceHolder<T>	take() Take a resource from the pool, waiting if necessary until an element becomes available.
ReferenceCountingResourceHolder<T>	take(long timeoutMs) Take a resource from the pool, waiting up to the specified wait time if necessary for an element to become available.
ReferenceCountingResourceHolder<List<T>>	takeBatch(int elementNum) Take resources from the pool, waiting if necessary until the elements of the given number become available.
ReferenceCountingResourceHolder<List<T>>	takeBatch(int elementNum, long timeoutMs) Take resources from the pool, waiting up to the specified wait time if necessary for elements of the given number to become available.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultBlockingPool

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

Method Detail

maxSize

public int maxSize()

Specified by:

maxSize in interface BlockingPool<T>

getPoolSize

public int getPoolSize()

take

public ReferenceCountingResourceHolder<T> take(long timeoutMs)

Description copied from interface: BlockingPool

Take a resource from the pool, waiting up to the specified wait time if necessary for an element to become available.

Specified by:

take in interface BlockingPool<T>

Parameters:

timeoutMs - maximum time to wait for a resource, in milliseconds.

Returns:

a resource, or null if the timeout was reached

take

public ReferenceCountingResourceHolder<T> take()

Description copied from interface: BlockingPool

Take a resource from the pool, waiting if necessary until an element becomes available.

Specified by:

take in interface BlockingPool<T>

Returns:

a resource

takeBatch

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

Description copied from interface: BlockingPool

Take resources from the pool, waiting up to the specified wait time if necessary for elements of the given number to become available.

Specified by:

takeBatch in interface BlockingPool<T>

Parameters:

elementNum - number of resources to take

timeoutMs - maximum time to wait for resources, in milliseconds.

Returns:

a resource, or null if the timeout was reached

takeBatch

public ReferenceCountingResourceHolder<List<T>> takeBatch(int elementNum)

Description copied from interface: BlockingPool

Take resources from the pool, waiting if necessary until the elements of the given number become available.

Specified by:

takeBatch in interface BlockingPool<T>

Parameters:

elementNum - number of resources to take

Returns:

a resource