Package | Description |
---|---|
org.glassfish.grizzly.connectionpool | |
org.glassfish.grizzly.http.server | |
org.glassfish.grizzly.threadpool | |
org.glassfish.grizzly.utils |
Constructor and Description |
---|
SingleEndpointPool(Endpoint<E> endpoint,
int corePoolSize,
int maxPoolSize,
DelayedExecutor.DelayQueue<SingleEndpointPool.ConnectTimeoutTask> connectTimeoutQueue,
DelayedExecutor.DelayQueue<SingleEndpointPool.ReconnectTask> reconnectQueue,
DelayedExecutor.DelayQueue<SingleEndpointPool.KeepAliveCleanerTask> keepAliveCleanerQueue,
DelayedExecutor.DelayQueue<Link<SingleEndpointPool.AsyncPoll>> asyncPollTimeoutQueue,
DelayedExecutor.DelayQueue<ConnectionInfo> connectionTTLQueue,
long connectTimeoutMillis,
long keepAliveTimeoutMillis,
long keepAliveCheckIntervalMillis,
long reconnectDelayMillis,
int maxReconnectAttempts,
long asyncPollTimeoutMillis,
long connectionTTLMillis,
boolean failFastWhenMaxSizeReached)
Constructs SingleEndpointPool instance.
|
SingleEndpointPool(Endpoint<E> endpoint,
int corePoolSize,
int maxPoolSize,
DelayedExecutor.DelayQueue<SingleEndpointPool.ConnectTimeoutTask> connectTimeoutQueue,
DelayedExecutor.DelayQueue<SingleEndpointPool.ReconnectTask> reconnectQueue,
DelayedExecutor.DelayQueue<SingleEndpointPool.KeepAliveCleanerTask> keepAliveCleanerQueue,
DelayedExecutor.DelayQueue<Link<SingleEndpointPool.AsyncPoll>> asyncPollTimeoutQueue,
DelayedExecutor.DelayQueue<ConnectionInfo> connectionTTLQueue,
long connectTimeoutMillis,
long keepAliveTimeoutMillis,
long keepAliveCheckIntervalMillis,
long reconnectDelayMillis,
int maxReconnectAttempts,
long asyncPollTimeoutMillis,
long connectionTTLMillis,
boolean failFastWhenMaxSizeReached)
Constructs SingleEndpointPool instance.
|
SingleEndpointPool(Endpoint<E> endpoint,
int corePoolSize,
int maxPoolSize,
DelayedExecutor.DelayQueue<SingleEndpointPool.ConnectTimeoutTask> connectTimeoutQueue,
DelayedExecutor.DelayQueue<SingleEndpointPool.ReconnectTask> reconnectQueue,
DelayedExecutor.DelayQueue<SingleEndpointPool.KeepAliveCleanerTask> keepAliveCleanerQueue,
DelayedExecutor.DelayQueue<Link<SingleEndpointPool.AsyncPoll>> asyncPollTimeoutQueue,
DelayedExecutor.DelayQueue<ConnectionInfo> connectionTTLQueue,
long connectTimeoutMillis,
long keepAliveTimeoutMillis,
long keepAliveCheckIntervalMillis,
long reconnectDelayMillis,
int maxReconnectAttempts,
long asyncPollTimeoutMillis,
long connectionTTLMillis,
boolean failFastWhenMaxSizeReached)
Constructs SingleEndpointPool instance.
|
SingleEndpointPool(Endpoint<E> endpoint,
int corePoolSize,
int maxPoolSize,
DelayedExecutor.DelayQueue<SingleEndpointPool.ConnectTimeoutTask> connectTimeoutQueue,
DelayedExecutor.DelayQueue<SingleEndpointPool.ReconnectTask> reconnectQueue,
DelayedExecutor.DelayQueue<SingleEndpointPool.KeepAliveCleanerTask> keepAliveCleanerQueue,
DelayedExecutor.DelayQueue<Link<SingleEndpointPool.AsyncPoll>> asyncPollTimeoutQueue,
DelayedExecutor.DelayQueue<ConnectionInfo> connectionTTLQueue,
long connectTimeoutMillis,
long keepAliveTimeoutMillis,
long keepAliveCheckIntervalMillis,
long reconnectDelayMillis,
int maxReconnectAttempts,
long asyncPollTimeoutMillis,
long connectionTTLMillis,
boolean failFastWhenMaxSizeReached)
Constructs SingleEndpointPool instance.
|
SingleEndpointPool(Endpoint<E> endpoint,
int corePoolSize,
int maxPoolSize,
DelayedExecutor.DelayQueue<SingleEndpointPool.ConnectTimeoutTask> connectTimeoutQueue,
DelayedExecutor.DelayQueue<SingleEndpointPool.ReconnectTask> reconnectQueue,
DelayedExecutor.DelayQueue<SingleEndpointPool.KeepAliveCleanerTask> keepAliveCleanerQueue,
DelayedExecutor.DelayQueue<Link<SingleEndpointPool.AsyncPoll>> asyncPollTimeoutQueue,
DelayedExecutor.DelayQueue<ConnectionInfo> connectionTTLQueue,
long connectTimeoutMillis,
long keepAliveTimeoutMillis,
long keepAliveCheckIntervalMillis,
long reconnectDelayMillis,
int maxReconnectAttempts,
long asyncPollTimeoutMillis,
long connectionTTLMillis,
boolean failFastWhenMaxSizeReached)
Constructs SingleEndpointPool instance.
|
Modifier and Type | Field and Description |
---|---|
protected DelayedExecutor.DelayQueue<Response.SuspendTimeout> |
Response.delayQueue |
Modifier and Type | Method and Description |
---|---|
void |
Response.initialize(Request request,
HttpResponsePacket response,
FilterChainContext ctx,
DelayedExecutor.DelayQueue<Response.SuspendTimeout> delayQueue,
HttpServerFilter serverFilter) |
Modifier and Type | Field and Description |
---|---|
protected DelayedExecutor.DelayQueue<AbstractThreadPool.Worker> |
AbstractThreadPool.delayedQueue |
Modifier and Type | Method and Description |
---|---|
<E> DelayedExecutor.DelayQueue<E> |
DelayedExecutor.createDelayQueue(DelayedExecutor.Worker<E> worker,
DelayedExecutor.Resolver<E> resolver) |
Copyright © 2021 Oracle Corporation. All rights reserved.