Package com.linkedin.alpini.base.pool.impl

Class AsyncQOSPoolImpl<T>

java.lang.Object

com.linkedin.alpini.base.pool.impl.AsyncPoolImpl<T>

com.linkedin.alpini.base.pool.impl.AsyncQOSPoolImpl<T>

All Implemented Interfaces:

AsyncPool<T>, AsyncQOSPool<T>, Shutdownable, ShutdownableResource

public class AsyncQOSPoolImpl<T>
extends AsyncPoolImpl<T>
implements AsyncQOSPool<T>

Nested Class Summary

Nested classes/interfaces inherited from class com.linkedin.alpini.base.pool.impl.AsyncPoolImpl

AsyncPoolImpl.ShutdownException, AsyncPoolImpl.TooManyWaitersException

Nested classes/interfaces inherited from interface com.linkedin.alpini.base.pool.AsyncPool

AsyncPool.LifeCycle<T>

Constructor Summary

Constructors

Constructor	Description
AsyncQOSPoolImpl(AsyncPool.LifeCycle<T> lifeCycle, QOSPolicy.StaticConfig qosPolicyConfig, java.util.concurrent.Executor executor, int maxConcurrentCreate, int minimumEntities, int maximumEntities, long maxIdleTime, java.util.concurrent.TimeUnit maxIdleUnit)

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.CompletableFuture<T>	acquire()
java.util.concurrent.CompletableFuture<T>	acquire(java.lang.String queueName, QOS qos)
protected java.util.concurrent.CompletableFuture<T>	acquire0(java.lang.String queueName, QOS qos)

Methods inherited from class com.linkedin.alpini.base.pool.impl.AsyncPoolImpl

acquire0, checkout, createCallTracker, dispose, dispose0, getPoolStats, isShutdown, isTerminated, release, release0, shutdown, shutdownPool, size, start, startWaiters, waitForShutdown, waitForShutdown

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.linkedin.alpini.base.pool.AsyncPool

dispose, getPoolStats, release, shutdownPool, size, start

Constructor Detail

AsyncQOSPoolImpl

public AsyncQOSPoolImpl(AsyncPool.LifeCycle<T> lifeCycle,
                        QOSPolicy.StaticConfig qosPolicyConfig,
                        java.util.concurrent.Executor executor,
                        int maxConcurrentCreate,
                        int minimumEntities,
                        int maximumEntities,
                        long maxIdleTime,
                        java.util.concurrent.TimeUnit maxIdleUnit)

Method Detail

acquire

public java.util.concurrent.CompletableFuture<T> acquire()

Specified by:

acquire in interface AsyncPool<T>

Overrides:

acquire in class AsyncPoolImpl<T>

acquire

public java.util.concurrent.CompletableFuture<T> acquire(java.lang.String queueName,
                                                         QOS qos)

Specified by:

acquire in interface AsyncQOSPool<T>

acquire0

protected final java.util.concurrent.CompletableFuture<T> acquire0(java.lang.String queueName,
                                                                   QOS qos)