com.oceanbase.jdbc.internal.util.scheduler

类 SchedulerServiceProviderHolder

java.lang.Object

com.oceanbase.jdbc.internal.util.scheduler.SchedulerServiceProviderHolder

public class SchedulerServiceProviderHolder
extends Object

Provider for when ever an internal thread pool is needed. This can allow library users to override our default pooling behavior with possibly better and faster options.

嵌套类概要

嵌套类

限定符和类型	类和说明
static interface	SchedulerServiceProviderHolder.SchedulerProvider Provider for thread pools which allow scheduling capabilities.

字段概要

字段

限定符和类型	字段和说明
static SchedulerServiceProviderHolder.SchedulerProvider	DEFAULT_PROVIDER The default provider will construct a new pool on every request.

构造器概要

构造器

构造器和说明
SchedulerServiceProviderHolder()

方法概要

限定符和类型	方法和说明
static void	close() Close currentProvider.
static ThreadPoolExecutor	getBulkScheduler()
static ScheduledExecutorService	getFixedSizeScheduler(int initialThreadCount, String poolName) Get a fixed sized scheduler directly with the current set provider.
static DynamicSizedSchedulerInterface	getScheduler(int initialThreadCount, String poolName, int maximumPoolSize) Get a Dynamic sized scheduler directly with the current set provider.
static SchedulerServiceProviderHolder.SchedulerProvider	getSchedulerProvider() Get the currently set SchedulerServiceProviderHolder.SchedulerProvider from set invocations via setSchedulerProvider(SchedulerProvider).
static ScheduledExecutorService	getTimeoutScheduler() Get a scheduler to handle timeout.
static void	setSchedulerProvider(SchedulerServiceProviderHolder.SchedulerProvider newProvider) Change the current set scheduler provider.

从类继承的方法 java.lang.Object

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

字段详细资料

DEFAULT_PROVIDER

public static final SchedulerServiceProviderHolder.SchedulerProvider DEFAULT_PROVIDER

The default provider will construct a new pool on every request.

构造器详细资料

SchedulerServiceProviderHolder

public SchedulerServiceProviderHolder()

方法详细资料

getSchedulerProvider

public static SchedulerServiceProviderHolder.SchedulerProvider getSchedulerProvider()

Get the currently set SchedulerServiceProviderHolder.SchedulerProvider from set invocations via setSchedulerProvider(SchedulerProvider). If none has been set a default provider will be provided (never a null result).

返回:

Provider to get scheduler pools from

setSchedulerProvider

public static void setSchedulerProvider(SchedulerServiceProviderHolder.SchedulerProvider newProvider)

Change the current set scheduler provider. This provider will be provided in future requests to getSchedulerProvider().

参数:

newProvider - New provider to use, or null to use the default provider

close

public static void close()

Close currentProvider.

getScheduler

public static DynamicSizedSchedulerInterface getScheduler(int initialThreadCount,
                                                          String poolName,
                                                          int maximumPoolSize)

Get a Dynamic sized scheduler directly with the current set provider.

参数:

initialThreadCount - Number of threads scheduler is allowed to grow to

poolName - name of pool to identify threads

maximumPoolSize - maximum pool size

返回:

Scheduler capable of providing the needed thread count

getFixedSizeScheduler

public static ScheduledExecutorService getFixedSizeScheduler(int initialThreadCount,
                                                             String poolName)

Get a fixed sized scheduler directly with the current set provider.

参数:

initialThreadCount - Number of threads scheduler is allowed to grow to

poolName - name of pool to identify threads

返回:

Scheduler capable of providing the needed thread count

getTimeoutScheduler

public static ScheduledExecutorService getTimeoutScheduler()

Get a scheduler to handle timeout.

返回:

Scheduler capable of providing the needed thread count

getBulkScheduler

public static ThreadPoolExecutor getBulkScheduler()