public class ExecutorManager extends BaseManager
BaseManager.ConnectionAwareOp, BaseManager.ResponseQueueCall, BaseManager.ResponsiveOperationHandler, BaseManager.ReturnResponseProcess, BaseManager.TargetAwareOp
BATCH_OPS_EXECUTOR_NAME, dataMemberCount, INTERNAL_OPS_EXECUTOR_NAME, localIdGen, logger, lsMembers, mapCalls, mapMembers, maxOperationLimit, maxOperationTimeout, node, qServiceThreadPacketCache, redoGiveUpThreshold, redoLogThreshold, redoWaitMillis, responsePollTimeout, systemLogService, thisAddress, thisMember
Modifier and Type | Method and Description |
---|---|
void |
appendFullState(StringBuffer sbState) |
void |
appendState(StringBuffer sbState) |
void |
call(String name,
DistributedTask dtask) |
void |
executeAsync(Runnable runnable) |
void |
executeLocally(Runnable runnable) |
void |
executeNow(Runnable runnable) |
void |
executeQueryTask(Runnable runnable) |
NamedExecutorService |
getDefaultExecutorService() |
NamedExecutorService |
getEventExecutorService() |
Set<String> |
getExecutorNames() |
Map<String,LocalExecutorOperationStatsImpl> |
getInternalThroughputMap() |
ParallelExecutor |
getMapLoaderExecutorService() |
NamedExecutorService |
getMapStoreExecutorService() |
NamedExecutorService |
getOrCreateNamedExecutorService(String name) |
ScheduledThreadPoolExecutor |
getScheduledExecutorService() |
Map<String,LocalExecutorOperationStatsImpl> |
getThroughputMap() |
ParallelExecutor |
newParallelExecutor(int concurrencyLevel) |
void |
stop() |
addRemoteCall, checkServiceThread, createRemotelyProcessablePacket, createSimpleMapEntry, enqueueAndReturn, enqueueAndWait, enqueueAndWait, getInstanceType, getMasterAddress, getMembers, getNextMemberAfter, getNextMemberAfter, getNode, getPacketProcessor, getRemoteCall, getThisAddress, handleInterruptedException, handleResponse, isActive, isLiteMember, isMaster, isMigrating, logRedo, obtainPacket, obtainPacket, registerPacketProcessor, releasePacket, removeRemoteCall, rethrowException, returnRedoResponse, returnResponse, returnResponse, send, send, sendEvents, sendOrReleasePacket, sendOrReleasePacket, sendProcessableTo, sendProcessableTo, sendProcessableToAll, sendResponse, sendResponse, sendResponseFailure
public NamedExecutorService getOrCreateNamedExecutorService(String name)
public ScheduledThreadPoolExecutor getScheduledExecutorService()
public ParallelExecutor getMapLoaderExecutorService()
public NamedExecutorService getMapStoreExecutorService()
public ParallelExecutor newParallelExecutor(int concurrencyLevel)
public void appendState(StringBuffer sbState)
public void appendFullState(StringBuffer sbState)
public void stop()
public NamedExecutorService getDefaultExecutorService()
public NamedExecutorService getEventExecutorService()
public void executeLocally(Runnable runnable)
public void executeAsync(Runnable runnable)
public void executeNow(Runnable runnable)
public void executeQueryTask(Runnable runnable)
public void call(String name, DistributedTask dtask)
public Map<String,LocalExecutorOperationStatsImpl> getThroughputMap()
public Map<String,LocalExecutorOperationStatsImpl> getInternalThroughputMap()
Copyright © 2013 Hazelcast, Inc.. All rights reserved.