接口 ExecutorRepository
-
- 所有已知实现类:
DefaultExecutorRepository
@SPI(value="default", scope=APPLICATION) public interface ExecutorRepository
-
-
方法概要
-
-
-
方法详细资料
-
createExecutorIfAbsent
ExecutorService createExecutorIfAbsent(URL url)
Called by both Client and Server. TODO, consider separate these two parts. When the Client or Server starts for the first time, generate a new threadpool according to the parameters specified.- 参数:
url-- 返回:
-
getExecutor
ExecutorService getExecutor(URL url)
Be careful,The semantics of this method are getOrDefaultExecutor- 参数:
url-- 返回:
-
updateThreadpool
void updateThreadpool(URL url, ExecutorService executor)
Modify some of the threadpool's properties according to the url, for example, coreSize, maxSize, ...- 参数:
url-executor-
-
getServiceExportExecutor
ScheduledExecutorService getServiceExportExecutor()
-
shutdownServiceExportExecutor
void shutdownServiceExportExecutor()
The executor only used in bootstrap currently, we should call this method to release the resource after the async export is done.
-
getServiceReferExecutor
ExecutorService getServiceReferExecutor()
-
shutdownServiceReferExecutor
void shutdownServiceReferExecutor()
The executor only used in bootstrap currently, we should call this method to release the resource after the async refer is done.
-
destroyAll
void destroyAll()
Destroy all executors that are not in shutdown state
-
nextScheduledExecutor
@Deprecated 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
@Deprecated ExecutorService nextExecutorExecutor()
已过时。- 返回:
- ExecutorService
-
getServiceDiscoveryAddressNotificationExecutor
@Deprecated ScheduledExecutorService getServiceDiscoveryAddressNotificationExecutor()
- 返回:
- ScheduledExecutorService
-
getMetadataRetryExecutor
@Deprecated ScheduledExecutorService getMetadataRetryExecutor()
已过时。- 返回:
- ScheduledExecutorService
-
getRegistryNotificationExecutor
@Deprecated ScheduledExecutorService getRegistryNotificationExecutor()
已过时。Scheduled executor handle registry notification.- 返回:
- ScheduledExecutorService
-
getSharedExecutor
@Deprecated ExecutorService getSharedExecutor()
已过时。useFrameworkExecutorRepository.getSharedExecutor()insteadGet the default shared threadpool.- 返回:
- ScheduledExecutorService
-
getSharedScheduledExecutor
@Deprecated ScheduledExecutorService getSharedScheduledExecutor()
已过时。Get the shared schedule executor- 返回:
- ScheduledExecutorService
-
getPoolRouterExecutor
@Deprecated ExecutorService getPoolRouterExecutor()
已过时。- 返回:
- ExecutorService
-
getConnectivityScheduledExecutor
@Deprecated ScheduledExecutorService getConnectivityScheduledExecutor()
已过时。Scheduled executor handle connectivity check task- 返回:
- ScheduledExecutorService
-
getCacheRefreshingScheduledExecutor
@Deprecated ScheduledExecutorService getCacheRefreshingScheduledExecutor()
已过时。Scheduler used to refresh file based caches from memory to disk.- 返回:
- ScheduledExecutorService
-
getMappingRefreshingExecutor
@Deprecated ExecutorService getMappingRefreshingExecutor()
已过时。Executor used to run async mapping tasks- 返回:
- ExecutorService
-
-