类 DefaultExecutorRepository
- java.lang.Object
-
- org.apache.dubbo.common.threadpool.manager.DefaultExecutorRepository
-
- 所有已实现的接口:
ExecutorRepository
public class DefaultExecutorRepository extends Object implements ExecutorRepository
Consider implementingLicycleto enable executors shutdown when the process stops.
-
-
字段概要
字段 修饰符和类型 字段 说明 ScheduledExecutorServiceregistryNotificationExecutor
-
构造器概要
构造器 构造器 说明 DefaultExecutorRepository()
-
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 ExecutorServicecreateExecutorIfAbsent(URL url)Get called when the server or client instance initiating.voiddestroyAll()Destroy all executors that are not in shutdown stateExecutorServicegetExecutor(URL url)ScheduledExecutorServicegetExportReferExecutor()ScheduledExecutorServicegetMetadataRetryExecutor()ExecutorServicegetPoolRouterExecutor()ScheduledExecutorServicegetRegistryNotificationExecutor()Scheduled executor handle registry notification.ScheduledExecutorServicegetServiceDiscoveryAddressNotificationExecutor()ExecutorServicegetSharedExecutor()Get the default shared threadpool.ExecutorServicenextExecutorExecutor()ScheduledExecutorServicenextScheduledExecutor()Returns a scheduler from the scheduler list, call this method whenever you need a scheduler for a cron job.voidshutdownExportReferExecutor()The executor only used in bootstrap currently, we should call this method to release the resource after the async export-refer is done.voidupdateThreadpool(URL url, ExecutorService executor)Modify some of the threadpool's properties according to the url, for example, coreSize, maxSize, ...
-
-
-
字段详细资料
-
registryNotificationExecutor
public ScheduledExecutorService registryNotificationExecutor
-
-
方法详细资料
-
createExecutorIfAbsent
public ExecutorService createExecutorIfAbsent(URL url)
Get called when the server or client instance initiating.- 指定者:
createExecutorIfAbsent在接口中ExecutorRepository- 参数:
url-- 返回:
-
getExecutor
public ExecutorService getExecutor(URL url)
- 指定者:
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
-
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- 返回:
-
nextExecutorExecutor
public ExecutorService nextExecutorExecutor()
- 指定者:
nextExecutorExecutor在接口中ExecutorRepository
-
getExportReferExecutor
public ScheduledExecutorService getExportReferExecutor()
- 指定者:
getExportReferExecutor在接口中ExecutorRepository
-
shutdownExportReferExecutor
public void shutdownExportReferExecutor()
从接口复制的说明:ExecutorRepositoryThe executor only used in bootstrap currently, we should call this method to release the resource after the async export-refer is done.
-
getRegistryNotificationExecutor
public ScheduledExecutorService getRegistryNotificationExecutor()
从接口复制的说明:ExecutorRepositoryScheduled executor handle registry notification.- 指定者:
getRegistryNotificationExecutor在接口中ExecutorRepository- 返回:
-
getServiceDiscoveryAddressNotificationExecutor
public ScheduledExecutorService getServiceDiscoveryAddressNotificationExecutor()
-
getMetadataRetryExecutor
public ScheduledExecutorService getMetadataRetryExecutor()
- 指定者:
getMetadataRetryExecutor在接口中ExecutorRepository
-
getSharedExecutor
public ExecutorService getSharedExecutor()
从接口复制的说明:ExecutorRepositoryGet the default shared threadpool.- 指定者:
getSharedExecutor在接口中ExecutorRepository- 返回:
-
getPoolRouterExecutor
public ExecutorService getPoolRouterExecutor()
- 指定者:
getPoolRouterExecutor在接口中ExecutorRepository
-
destroyAll
public void destroyAll()
从接口复制的说明:ExecutorRepositoryDestroy all executors that are not in shutdown state- 指定者:
destroyAll在接口中ExecutorRepository
-
-