com.oceanbase.jdbc.internal.util.scheduler

接口 SchedulerServiceProviderHolder.SchedulerProvider

封闭类:

SchedulerServiceProviderHolder

public static interface SchedulerServiceProviderHolder.SchedulerProvider

Provider for thread pools which allow scheduling capabilities. It is expected that the thread pools entire lifecycle (start to stop) is done through the same provider instance.

方法概要

限定符和类型	方法和说明
void	close()
ThreadPoolExecutor	getBulkScheduler()
ScheduledExecutorService	getFixedSizeScheduler(int minimumThreads, String poolName)
DynamicSizedSchedulerInterface	getScheduler(int minimumThreads, String poolName, int maximumPoolSize) Request to get a scheduler with a minimum number of AVAILABLE threads.
ScheduledThreadPoolExecutor	getTimeoutScheduler() Default Timeout scheduler.

方法详细资料

getScheduler

DynamicSizedSchedulerInterface getScheduler(int minimumThreads,
                                            String poolName,
                                            int maximumPoolSize)

Request to get a scheduler with a minimum number of AVAILABLE threads.

参数:

minimumThreads - Minimum number of available threads for the returned scheduler

poolName - name of pool to identify threads

maximumPoolSize - maximum pool size

返回:

A new scheduler that is ready to accept tasks

getFixedSizeScheduler

ScheduledExecutorService getFixedSizeScheduler(int minimumThreads,
                                               String poolName)

getTimeoutScheduler

ScheduledThreadPoolExecutor getTimeoutScheduler()

Default Timeout scheduler.

This is a one Thread fixed sized scheduler. This specific scheduler is using java 1.7 RemoveOnCancelPolicy, so the task are removed from queue permitting to avoid memory consumption [CONJ-297]

返回:

A new scheduler that is ready to accept tasks

getBulkScheduler

ThreadPoolExecutor getBulkScheduler()

close

void close()