org.glassfish.jersey.client

Class DefaultClientAsyncExecutorProvider

java.lang.Object

org.glassfish.jersey.spi.AbstractThreadPoolProvider<java.util.concurrent.ThreadPoolExecutor>

org.glassfish.jersey.spi.ThreadPoolExecutorProvider

org.glassfish.jersey.client.DefaultClientAsyncExecutorProvider

All Implemented Interfaces:

ExecutorServiceProvider

@ClientAsyncExecutor
class DefaultClientAsyncExecutorProvider
extends ThreadPoolExecutorProvider

Default ExecutorServiceProvider used on the client side for asynchronous request processing.

Field Summary

Fields

Modifier and Type	Field and Description
private LazyValue<java.lang.Integer>	asyncThreadPoolSize
private static java.util.logging.Logger	LOGGER

Fields inherited from class org.glassfish.jersey.spi.AbstractThreadPoolProvider

DEFAULT_TERMINATION_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
DefaultClientAsyncExecutorProvider(int poolSize) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
protected int	getCorePoolSize() Get the number of the core threads of the the provisioned thread pool executor.
protected int	getMaximumPoolSize() Get the maximum number of threads to allow in the thread pool.

Methods inherited from class org.glassfish.jersey.spi.ThreadPoolExecutorProvider

createExecutor, createExecutor, dispose, getExecutorService, getKeepAliveTime, getWorkQueue, preDestroy

Methods inherited from class org.glassfish.jersey.spi.AbstractThreadPoolProvider

close, getBackingThreadFactory, getExecutor, getRejectedExecutionHandler, getTerminationTimeout, isClosed, onClose

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final java.util.logging.Logger LOGGER

asyncThreadPoolSize

private final LazyValue<java.lang.Integer> asyncThreadPoolSize

Constructor Detail

DefaultClientAsyncExecutorProvider

@Inject
public DefaultClientAsyncExecutorProvider(@Named(value="ClientAsyncThreadPoolSize")
                                                  int poolSize)

Creates a new instance.

Parameters:

poolSize - size of the default executor thread pool (if used). Zero or negative values are ignored. See also ClientProperties.ASYNC_THREADPOOL_SIZE.

Method Detail

getMaximumPoolSize

protected int getMaximumPoolSize()

Description copied from class: ThreadPoolExecutorProvider

Get the maximum number of threads to allow in the thread pool.

The value from this method is passed as one of the input parameters in a call to the ThreadPoolExecutorProvider.createExecutor(int, int, long, java.util.concurrent.BlockingQueue, java.util.concurrent.ThreadFactory, java.util.concurrent.RejectedExecutionHandler) method.

The method can be overridden to customize the maximum number of threads allowed in the provisioned thread pool executor. If not customized, the method defaults to Integer.MAX_VALUE.

Overrides:

getMaximumPoolSize in class ThreadPoolExecutorProvider

Returns:

maximum number of threads allowed in the thread pool.

getCorePoolSize

protected int getCorePoolSize()

Description copied from class: AbstractThreadPoolProvider

Get the number of the core threads of the the provisioned thread pool executor.

The value from this method is passed as one of the input parameters in a call to the AbstractThreadPoolProvider.createExecutor(int, java.util.concurrent.ThreadFactory, java.util.concurrent.RejectedExecutionHandler) method.

The method can be overridden to customize the number of core threads of the provisioned thread pool executor. If not customized, the method defaults to the number of available processors in the system.

Overrides:

getCorePoolSize in class AbstractThreadPoolProvider<java.util.concurrent.ThreadPoolExecutor>

Returns:

number of core threads in the provisioned thread pool executor.

See Also:

AbstractThreadPoolProvider.createExecutor(int, java.util.concurrent.ThreadFactory, java.util.concurrent.RejectedExecutionHandler)