public interface SynchronizationInternal extends Serializable
| Modifier and Type | Method and Description |
|---|---|
boolean |
channelExists(String originator,
TaskId taskid,
String name) |
void |
clear(String originator,
TaskId taskid,
String channel) |
Serializable |
compute(String originator,
TaskId taskid,
String channel,
String key,
String remappingFunction) |
Serializable |
computeIfAbsent(String originator,
TaskId taskid,
String channel,
String key,
String mappingFunction) |
Serializable |
computeIfPresent(String originator,
TaskId taskid,
String channel,
String key,
String remappingFunction) |
PredicateActionResult |
conditionalCompute(String originator,
TaskId taskid,
String channel,
String key,
String predicate,
String thenRemappingFunction) |
PredicateActionResult |
conditionalCompute(String originator,
TaskId taskid,
String channel,
String key,
String predicate,
String thenRemappingFunction,
String elseRemappingFunction) |
void |
conditionalReplaceAll(String originator,
TaskId taskid,
String channel,
String predicate,
String thenRemappingFunction) |
void |
conditionalReplaceAll(String originator,
TaskId taskid,
String channel,
String predicate,
String thenRemappingFunction,
String elseRemappingFunction) |
boolean |
containsKey(String originator,
TaskId taskid,
String channel,
String key) |
boolean |
containsValue(String originator,
TaskId taskid,
String channel,
Serializable value) |
boolean |
createChannel(String originator,
TaskId taskid,
String name,
boolean isPersistent) |
boolean |
createChannelIfAbsent(String originator,
TaskId taskid,
String name,
boolean isPersistent) |
boolean |
deleteChannel(String originator,
TaskId taskid,
String name) |
Set<Map.Entry<String,Serializable>> |
entrySet(String originator,
TaskId taskid,
String channel) |
void |
forEach(String originator,
TaskId taskid,
String channel,
String action) |
void |
freeze() |
Serializable |
get(String originator,
TaskId taskid,
String channel,
String key) |
Serializable |
getOrDefault(String originator,
TaskId taskid,
String channel,
String key,
Serializable defaultValue) |
boolean |
isEmpty(String originator,
TaskId taskid,
String channel) |
Set<String> |
keySet(String originator,
TaskId taskid,
String channel) |
Serializable |
merge(String originator,
TaskId taskid,
String channel,
String key,
Serializable value,
String remappingFunction) |
Serializable |
put(String originator,
TaskId taskid,
String channel,
String key,
Serializable value) |
void |
putAll(String originator,
TaskId taskid,
String channel,
Map<? extends String,? extends Serializable> m) |
Serializable |
putIfAbsent(String originator,
TaskId taskid,
String channel,
String key,
Serializable value) |
Serializable |
remove(String originator,
TaskId taskid,
String channel,
String key) |
boolean |
remove(String originator,
TaskId taskid,
String channel,
String key,
Serializable value) |
Serializable |
replace(String originator,
TaskId taskid,
String channel,
String key,
Serializable value) |
boolean |
replace(String originator,
TaskId taskid,
String channel,
String key,
Serializable oldValue,
Serializable newValue) |
void |
replaceAll(String originator,
TaskId taskid,
String channel,
String function) |
void |
resume() |
int |
size(String originator,
TaskId taskid,
String channel) |
Collection<Serializable> |
values(String originator,
TaskId taskid,
String channel) |
boolean |
waitUntil(String originator,
TaskId taskid,
String channel,
String key,
String predicate) |
boolean |
waitUntil(String originator,
TaskId taskid,
String channel,
String key,
String predicate,
long timeout) |
String |
waitUntilAny(String originator,
TaskId taskid,
String channel,
Set<String> keys,
String predicate) |
PredicateActionResult |
waitUntilThen(String originator,
TaskId taskid,
String channel,
String key,
String predicate,
long timeout,
String thenRemappingFunction) |
PredicateActionResult |
waitUntilThen(String originator,
TaskId taskid,
String channel,
String key,
String predicate,
String thenRemappingFunction) |
boolean createChannel(String originator, TaskId taskid, String name, boolean isPersistent) throws IOException
IOExceptionboolean createChannelIfAbsent(String originator, TaskId taskid, String name, boolean isPersistent) throws IOException
IOExceptionboolean deleteChannel(String originator, TaskId taskid, String name) throws IOException
IOExceptionint size(String originator, TaskId taskid, String channel) throws InvalidChannelException
InvalidChannelExceptionboolean isEmpty(String originator, TaskId taskid, String channel) throws InvalidChannelException
InvalidChannelExceptionboolean containsKey(String originator, TaskId taskid, String channel, String key) throws InvalidChannelException
InvalidChannelExceptionboolean containsValue(String originator, TaskId taskid, String channel, Serializable value) throws InvalidChannelException
InvalidChannelExceptionSerializable get(String originator, TaskId taskid, String channel, String key) throws InvalidChannelException
InvalidChannelExceptionSerializable put(String originator, TaskId taskid, String channel, String key, Serializable value) throws InvalidChannelException, IOException
InvalidChannelExceptionIOExceptionSerializable remove(String originator, TaskId taskid, String channel, String key) throws InvalidChannelException, IOException
InvalidChannelExceptionIOExceptionvoid putAll(String originator, TaskId taskid, String channel, Map<? extends String,? extends Serializable> m) throws InvalidChannelException, IOException
InvalidChannelExceptionIOExceptionvoid clear(String originator, TaskId taskid, String channel) throws InvalidChannelException, IOException
InvalidChannelExceptionIOExceptionSet<String> keySet(String originator, TaskId taskid, String channel) throws InvalidChannelException
InvalidChannelExceptionCollection<Serializable> values(String originator, TaskId taskid, String channel) throws InvalidChannelException
InvalidChannelExceptionSet<Map.Entry<String,Serializable>> entrySet(String originator, TaskId taskid, String channel) throws InvalidChannelException
InvalidChannelExceptionSerializable getOrDefault(String originator, TaskId taskid, String channel, String key, Serializable defaultValue) throws InvalidChannelException
InvalidChannelExceptionvoid forEach(String originator, TaskId taskid, String channel, String action) throws InvalidChannelException, CompilationException
void replaceAll(String originator, TaskId taskid, String channel, String function) throws InvalidChannelException, CompilationException, IOException
Serializable putIfAbsent(String originator, TaskId taskid, String channel, String key, Serializable value) throws InvalidChannelException, IOException
InvalidChannelExceptionIOExceptionboolean remove(String originator, TaskId taskid, String channel, String key, Serializable value) throws InvalidChannelException, IOException
InvalidChannelExceptionIOExceptionboolean replace(String originator, TaskId taskid, String channel, String key, Serializable oldValue, Serializable newValue) throws InvalidChannelException, IOException
InvalidChannelExceptionIOExceptionSerializable replace(String originator, TaskId taskid, String channel, String key, Serializable value) throws InvalidChannelException, IOException
InvalidChannelExceptionIOExceptionSerializable computeIfAbsent(String originator, TaskId taskid, String channel, String key, String mappingFunction) throws InvalidChannelException, CompilationException, IOException
Serializable computeIfPresent(String originator, TaskId taskid, String channel, String key, String remappingFunction) throws InvalidChannelException, CompilationException, IOException
Serializable compute(String originator, TaskId taskid, String channel, String key, String remappingFunction) throws InvalidChannelException, CompilationException, IOException
Serializable merge(String originator, TaskId taskid, String channel, String key, Serializable value, String remappingFunction) throws InvalidChannelException, CompilationException, IOException
PredicateActionResult conditionalCompute(String originator, TaskId taskid, String channel, String key, String predicate, String thenRemappingFunction) throws InvalidChannelException, CompilationException, IOException
PredicateActionResult conditionalCompute(String originator, TaskId taskid, String channel, String key, String predicate, String thenRemappingFunction, String elseRemappingFunction) throws InvalidChannelException, CompilationException, IOException
void conditionalReplaceAll(String originator, TaskId taskid, String channel, String predicate, String thenRemappingFunction) throws InvalidChannelException, CompilationException, IOException
void conditionalReplaceAll(String originator, TaskId taskid, String channel, String predicate, String thenRemappingFunction, String elseRemappingFunction) throws InvalidChannelException, CompilationException, IOException
boolean waitUntil(String originator, TaskId taskid, String channel, String key, String predicate) throws InvalidChannelException, CompilationException
boolean waitUntil(String originator, TaskId taskid, String channel, String key, String predicate, long timeout) throws InvalidChannelException, CompilationException, TimeoutException
String waitUntilAny(String originator, TaskId taskid, String channel, Set<String> keys, String predicate) throws InvalidChannelException, CompilationException
PredicateActionResult waitUntilThen(String originator, TaskId taskid, String channel, String key, String predicate, String thenRemappingFunction) throws InvalidChannelException, CompilationException, IOException
PredicateActionResult waitUntilThen(String originator, TaskId taskid, String channel, String key, String predicate, long timeout, String thenRemappingFunction) throws InvalidChannelException, CompilationException, IOException, TimeoutException
void freeze()
throws IOException
IOExceptionvoid resume()
throws IOException
IOException