Module io.helidon.jersey.client

Package io.helidon.jersey.client

Class ExecutorProvider

java.lang.Object

org.glassfish.jersey.spi.AbstractThreadPoolProvider<ThreadPoolExecutor>

org.glassfish.jersey.spi.ThreadPoolExecutorProvider

io.helidon.jersey.client.ExecutorProvider

All Implemented Interfaces:

AutoCloseable, ExecutorServiceProvider

@ClientAsyncExecutor
public class ExecutorProvider
extends ThreadPoolExecutorProvider

Wraps default executor to enable Helidon context propagation for Jersey async calls.

Field Summary

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

DEFAULT_TERMINATION_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
ExecutorProvider(Optional<Integer> poolSize)	Create new instance of the context aware executor provider.

Method Summary

Modifier and Type	Method	Description
protected int	getCorePoolSize()
ExecutorService	getExecutorService()
protected int	getMaximumPoolSize()

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

createExecutor, createExecutor, dispose, 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

Constructor Details

ExecutorProvider

@Inject
public ExecutorProvider(@Named("ClientAsyncThreadPoolSize")
 Optional<Integer> poolSize)

Create new instance of the context aware executor provider.

Parameters:

poolSize - Maximum pool size

Method Details

getMaximumPoolSize

protected int getMaximumPoolSize()

Overrides:

getMaximumPoolSize in class ThreadPoolExecutorProvider

getCorePoolSize

protected int getCorePoolSize()

Overrides:

getCorePoolSize in class AbstractThreadPoolProvider<ThreadPoolExecutor>

getExecutorService

public ExecutorService getExecutorService()

Specified by:

getExecutorService in interface ExecutorServiceProvider

Overrides:

getExecutorService in class ThreadPoolExecutorProvider