public class DistributedExecutorService extends Object implements ManagedService, RemoteService, ExecutionTracingService, StatisticsAwareService
Modifier and Type | Field and Description |
---|---|
static String |
SERVICE_NAME |
Constructor and Description |
---|
DistributedExecutorService() |
Modifier and Type | Method and Description |
---|---|
boolean |
cancel(String uuid,
boolean interrupt) |
ExecutorServiceProxy |
createDistributedObject(String name)
Creates a distributed object.
|
void |
destroyDistributedObject(String name)
Destroys a distributed object.
|
void |
execute(String name,
String uuid,
Callable callable,
Operation op) |
Map<String,LocalExecutorStats> |
getStats() |
void |
init(NodeEngine nodeEngine,
Properties properties)
Initializes this ManagedService
|
boolean |
isOperationExecuting(Address callerAddress,
String callerUuid,
Object identifier) |
boolean |
isShutdown(String name) |
void |
reset()
reset this ManagedService back to initial state.
|
void |
shutdown(boolean terminate)
Shuts down this ManagedService.
|
void |
shutdownExecutor(String name) |
public static final String SERVICE_NAME
public void init(NodeEngine nodeEngine, Properties properties)
ManagedService
init
in interface ManagedService
nodeEngine
- the NodeEngine that this ManagedService belongs to.properties
- the Properties. Can be used to pass settings to the service.public void reset()
ManagedService
reset
in interface ManagedService
public void shutdown(boolean terminate)
ManagedService
shutdown
in interface ManagedService
terminate
- true to shut down the ManagedServicepublic boolean cancel(String uuid, boolean interrupt)
public void shutdownExecutor(String name)
public boolean isShutdown(String name)
public ExecutorServiceProxy createDistributedObject(String name)
RemoteService
createDistributedObject
in interface RemoteService
name
- the name for the created distributed objectpublic void destroyDistributedObject(String name)
RemoteService
destroyDistributedObject
in interface RemoteService
name
- the name of the distributed object to destroypublic boolean isOperationExecuting(Address callerAddress, String callerUuid, Object identifier)
isOperationExecuting
in interface ExecutionTracingService
public Map<String,LocalExecutorStats> getStats()
getStats
in interface StatisticsAwareService
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.