类 DefaultExecutorRepository
- java.lang.Object
-
- org.apache.dubbo.common.threadpool.manager.DefaultExecutorRepository
-
- 所有已实现的接口:
ExtensionAccessorAware,ExecutorRepository
public class DefaultExecutorRepository extends Object implements ExecutorRepository, ExtensionAccessorAware
Consider implementingLicycleto enable executors shutdown when the process stops.
-
-
构造器概要
构造器 构造器 说明 DefaultExecutorRepository(ApplicationModel applicationModel)
-
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 ExecutorServicecreateExecutorIfAbsent(URL url)Get called when the server or client instance initiating.voiddestroyAll()Destroy all executors that are not in shutdown stateScheduledExecutorServicegetCacheRefreshingScheduledExecutor()Scheduler used to refresh file based caches from memory to disk.ScheduledExecutorServicegetConnectivityScheduledExecutor()Scheduled executor handle connectivity check taskExecutorServicegetExecutor(URL url)Be careful,The semantics of this method are getOrDefaultExecutorExecutorServicegetMappingRefreshingExecutor()Executor used to run async mapping tasksScheduledExecutorServicegetMetadataRetryExecutor()ExecutorServicegetPoolRouterExecutor()ScheduledExecutorServicegetRegistryNotificationExecutor()Scheduled executor handle registry notification.ScheduledExecutorServicegetServiceDiscoveryAddressNotificationExecutor()ScheduledExecutorServicegetServiceExportExecutor()ExecutorServicegetServiceReferExecutor()ExecutorServicegetSharedExecutor()Get the default shared threadpool.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.voidsetExtensionAccessor(ExtensionAccessor extensionAccessor)voidshutdownServiceExportExecutor()The executor only used in bootstrap currently, we should call this method to release the resource after the async export is done.voidshutdownServiceReferExecutor()The executor only used in bootstrap currently, we should call this method to release the resource after the async refer is done.voidupdateThreadpool(URL url, ExecutorService executor)Modify some of the threadpool's properties according to the url, for example, coreSize, maxSize, ...
-
-
-
构造器详细资料
-
DefaultExecutorRepository
public DefaultExecutorRepository(ApplicationModel applicationModel)
-
-
方法详细资料
-
createExecutorIfAbsent
public ExecutorService createExecutorIfAbsent(URL url)
Get called when the server or client instance initiating.- 指定者:
createExecutorIfAbsent在接口中ExecutorRepository- 参数:
url-- 返回:
-
getExecutor
public ExecutorService getExecutor(URL url)
从接口复制的说明:ExecutorRepositoryBe careful,The semantics of this method are getOrDefaultExecutor- 指定者:
getExecutor在接口中ExecutorRepository- 返回:
-
updateThreadpool
public void updateThreadpool(URL url, ExecutorService executor)
从接口复制的说明:ExecutorRepositoryModify some of the threadpool's properties according to the url, for example, coreSize, maxSize, ...- 指定者:
updateThreadpool在接口中ExecutorRepository
-
getServiceExportExecutor
public ScheduledExecutorService getServiceExportExecutor()
- 指定者:
getServiceExportExecutor在接口中ExecutorRepository
-
shutdownServiceExportExecutor
public void shutdownServiceExportExecutor()
从接口复制的说明:ExecutorRepositoryThe executor only used in bootstrap currently, we should call this method to release the resource after the async export is done.
-
getServiceReferExecutor
public ExecutorService getServiceReferExecutor()
- 指定者:
getServiceReferExecutor在接口中ExecutorRepository
-
shutdownServiceReferExecutor
public void shutdownServiceReferExecutor()
从接口复制的说明:ExecutorRepositoryThe executor only used in bootstrap currently, we should call this method to release the resource after the async refer is done.
-
destroyAll
public void destroyAll()
从接口复制的说明:ExecutorRepositoryDestroy all executors that are not in shutdown state- 指定者:
destroyAll在接口中ExecutorRepository
-
setExtensionAccessor
public void setExtensionAccessor(ExtensionAccessor extensionAccessor)
- 指定者:
setExtensionAccessor在接口中ExtensionAccessorAware
-
nextScheduledExecutor
public ScheduledExecutorService nextScheduledExecutor()
从接口复制的说明:ExecutorRepositoryReturns 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.- 指定者:
nextScheduledExecutor在接口中ExecutorRepository- 返回:
- ScheduledExecutorService
-
nextExecutorExecutor
public ExecutorService nextExecutorExecutor()
- 指定者:
nextExecutorExecutor在接口中ExecutorRepository- 返回:
- ExecutorService
-
getServiceDiscoveryAddressNotificationExecutor
public ScheduledExecutorService getServiceDiscoveryAddressNotificationExecutor()
- 指定者:
getServiceDiscoveryAddressNotificationExecutor在接口中ExecutorRepository- 返回:
- ScheduledExecutorService
-
getMetadataRetryExecutor
public ScheduledExecutorService getMetadataRetryExecutor()
- 指定者:
getMetadataRetryExecutor在接口中ExecutorRepository- 返回:
- ScheduledExecutorService
-
getRegistryNotificationExecutor
public ScheduledExecutorService getRegistryNotificationExecutor()
从接口复制的说明:ExecutorRepositoryScheduled executor handle registry notification.- 指定者:
getRegistryNotificationExecutor在接口中ExecutorRepository- 返回:
- ScheduledExecutorService
-
getSharedExecutor
public ExecutorService getSharedExecutor()
从接口复制的说明:ExecutorRepositoryGet the default shared threadpool.- 指定者:
getSharedExecutor在接口中ExecutorRepository- 返回:
- ScheduledExecutorService
-
getSharedScheduledExecutor
public ScheduledExecutorService getSharedScheduledExecutor()
从接口复制的说明:ExecutorRepositoryGet the shared schedule executor- 指定者:
getSharedScheduledExecutor在接口中ExecutorRepository- 返回:
- ScheduledExecutorService
-
getPoolRouterExecutor
public ExecutorService getPoolRouterExecutor()
- 指定者:
getPoolRouterExecutor在接口中ExecutorRepository- 返回:
- ExecutorService
-
getConnectivityScheduledExecutor
public ScheduledExecutorService getConnectivityScheduledExecutor()
从接口复制的说明:ExecutorRepositoryScheduled executor handle connectivity check task- 指定者:
getConnectivityScheduledExecutor在接口中ExecutorRepository- 返回:
- ScheduledExecutorService
-
getCacheRefreshingScheduledExecutor
public ScheduledExecutorService getCacheRefreshingScheduledExecutor()
从接口复制的说明:ExecutorRepositoryScheduler used to refresh file based caches from memory to disk.- 指定者:
getCacheRefreshingScheduledExecutor在接口中ExecutorRepository- 返回:
- ScheduledExecutorService
-
getMappingRefreshingExecutor
public ExecutorService getMappingRefreshingExecutor()
从接口复制的说明:ExecutorRepositoryExecutor used to run async mapping tasks- 指定者:
getMappingRefreshingExecutor在接口中ExecutorRepository- 返回:
- ExecutorService
-
-