类 FrameworkExecutorRepository
- java.lang.Object
-
- org.apache.dubbo.common.threadpool.manager.FrameworkExecutorRepository
-
- 所有已实现的接口:
Disposable
public class FrameworkExecutorRepository extends Object implements Disposable
-
-
字段概要
字段 修饰符和类型 字段 说明 Ring<ScheduledExecutorService>registryNotificationExecutorRing
-
构造器概要
构造器 构造器 说明 FrameworkExecutorRepository()
-
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 voiddestroy()ScheduledExecutorServicegetCacheRefreshingScheduledExecutor()Scheduler used to refresh file based caches from memory to disk.ScheduledExecutorServicegetConnectivityScheduledExecutor()Scheduled executor handle connectivity check taskExecutorServicegetMappingRefreshingExecutor()Executor used to run async mapping tasksScheduledExecutorServicegetMetadataRetryExecutor()ExecutorServicegetPoolRouterExecutor()ScheduledExecutorServicegetRegistryNotificationExecutor()Scheduled executor handle registry notification.ScheduledExecutorServicegetServiceDiscoveryAddressNotificationExecutor()ExecutorServicegetSharedExecutor()Get the default shared thread pool.ScheduledExecutorServicegetSharedScheduledExecutor()Get the shared schedule executorExecutorServicenextExecutorExecutor()ScheduledExecutorServicenextScheduledExecutor()Returns a scheduler from the scheduler list, call this method whenever you need a scheduler for a cron job.
-
-
-
字段详细资料
-
registryNotificationExecutorRing
public final Ring<ScheduledExecutorService> registryNotificationExecutorRing
-
-
方法详细资料
-
nextScheduledExecutor
public ScheduledExecutorService nextScheduledExecutor()
Returns a scheduler from the scheduler list, call this method whenever you need a scheduler for a cron job. If your cron cannot burden the possible schedule delay caused by sharing the same scheduler, please consider define a dedicate one.- 返回:
- ScheduledExecutorService
-
nextExecutorExecutor
public ExecutorService nextExecutorExecutor()
-
getRegistryNotificationExecutor
public ScheduledExecutorService getRegistryNotificationExecutor()
Scheduled executor handle registry notification.- 返回:
- ScheduledExecutorService
-
getServiceDiscoveryAddressNotificationExecutor
public ScheduledExecutorService getServiceDiscoveryAddressNotificationExecutor()
-
getMetadataRetryExecutor
public ScheduledExecutorService getMetadataRetryExecutor()
-
getSharedExecutor
public ExecutorService getSharedExecutor()
Get the default shared thread pool.- 返回:
- ExecutorService
-
getSharedScheduledExecutor
public ScheduledExecutorService getSharedScheduledExecutor()
Get the shared schedule executor- 返回:
- ScheduledExecutorService
-
getPoolRouterExecutor
public ExecutorService getPoolRouterExecutor()
-
getConnectivityScheduledExecutor
public ScheduledExecutorService getConnectivityScheduledExecutor()
Scheduled executor handle connectivity check task- 返回:
- ScheduledExecutorService
-
getCacheRefreshingScheduledExecutor
public ScheduledExecutorService getCacheRefreshingScheduledExecutor()
Scheduler used to refresh file based caches from memory to disk.- 返回:
- ScheduledExecutorService
-
getMappingRefreshingExecutor
public ExecutorService getMappingRefreshingExecutor()
Executor used to run async mapping tasks- 返回:
- ExecutorService
-
destroy
public void destroy()
- 指定者:
destroy在接口中Disposable
-
-