public class DistributedExecutorService extends Object implements ManagedService, RemoteService, StatisticsAwareService<LocalExecutorStats>, SplitBrainProtectionAwareService
Modifier and Type | Field and Description |
---|---|
static String |
SERVICE_NAME |
Constructor and Description |
---|
DistributedExecutorService() |
Modifier and Type | Method and Description |
---|---|
boolean |
cancel(UUID uuid,
boolean interrupt) |
ExecutorServiceProxy |
createDistributedObject(String name,
boolean local)
Creates a distributed object on the local member only (when
local is
true ), else cluster-wide. |
void |
destroyDistributedObject(String name,
boolean local)
Destroys a distributed object.
|
<T> void |
execute(String name,
UUID uuid,
T task,
Operation op) |
String |
getName(UUID uuid) |
String |
getSplitBrainProtectionName(String name)
Gets the name of the split brain protection associated with specified operation name.
|
Map<String,LocalExecutorStats> |
getStats()
Return the service statistics for the local instance.
|
void |
init(NodeEngine nodeEngine,
Properties properties)
Initializes this service.
|
boolean |
isShutdown(String name) |
void |
reset()
Resets this service back to its initial state.
|
void |
shutdown(boolean terminate)
Shuts down this service.
|
void |
shutdownExecutor(String name) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createDistributedObject, destroyDistributedObject
public static final String SERVICE_NAME
public void init(NodeEngine nodeEngine, Properties properties)
ManagedService
init
in interface ManagedService
nodeEngine
- the NodeEngine that this service belongs toproperties
- the Properties (can be used to pass settings to the service)public void reset()
ManagedService
TODO: what is the purpose of reset
reset
in interface ManagedService
public void shutdown(boolean terminate)
ManagedService
TODO: what is the purpose of the terminate variable
shutdown
in interface ManagedService
terminate
- true
to shut down this servicepublic boolean cancel(UUID uuid, boolean interrupt)
public void shutdownExecutor(String name)
public boolean isShutdown(String name)
public ExecutorServiceProxy createDistributedObject(String name, boolean local)
RemoteService
local
is
true
), else cluster-wide.createDistributedObject
in interface RemoteService
name
- the name for the created distributed objectlocal
- when true
then only perform required proxy creation
actions on the local member, otherwise perform cluster-wide
proxy creation.public void destroyDistributedObject(String name, boolean local)
RemoteService
destroyDistributedObject
in interface RemoteService
name
- the name of the distributed object to destroypublic Map<String,LocalExecutorStats> getStats()
StatisticsAwareService
getStats
in interface StatisticsAwareService<LocalExecutorStats>
public String getSplitBrainProtectionName(String name)
SplitBrainProtectionAwareService
getSplitBrainProtectionName
in interface SplitBrainProtectionAwareService
name
- the operation name for which the split brain protection name is returnedCopyright © 2019 Hazelcast, Inc.. All rights reserved.