Package com.linkedin.alpini.base.pool

Interface AsyncQOSPool<T>

All Superinterfaces:

AsyncPool<T>

All Known Implementing Classes:

AsyncQOSPoolImpl

public interface AsyncQOSPool<T>
extends AsyncPool<T>

Nested Class Summary

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

AsyncPool.LifeCycle<T>

Method Summary

Modifier and Type	Method	Description
java.util.concurrent.CompletableFuture<T>	acquire(java.lang.String queueName, QOS qos)
static <T> AsyncQOSPool<T>	create(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)

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

acquire, dispose, getPoolStats, release, shutdownPool, size, start

Method Detail

acquire

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

create

static <T> AsyncQOSPool<T> create(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)