public abstract class AbstractCacheSyncListenerCompleter extends Object implements CacheSyncListenerCompleter
CacheSyncListenerCompleter
implementation which provides storage and management of countdown latches
and cache entry listener registrations.Constructor and Description |
---|
AbstractCacheSyncListenerCompleter() |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
awaitLatch(CountDownLatch countDownLatch,
InternalCompletableFuture future) |
void |
clearListeners() |
void |
countDownCompletionLatch(int countDownLatchId) |
void |
deregisterCompletionLatch(Integer countDownLatchId) |
UUID |
getListenerId(javax.cache.configuration.CacheEntryListenerConfiguration configuration) |
Collection<UUID> |
getListenersIds(boolean sync) |
void |
putListenerIfAbsent(javax.cache.configuration.CacheEntryListenerConfiguration configuration,
UUID regId) |
Integer |
registerCompletionLatch(int count) |
Integer |
registerCompletionLatch(Integer countDownLatchId,
int count) |
UUID |
removeListener(javax.cache.configuration.CacheEntryListenerConfiguration configuration) |
void |
waitCompletionLatch(Integer countDownLatchId) |
void |
waitCompletionLatch(Integer countDownLatchId,
int offset) |
void |
waitCompletionLatch(Integer countDownLatchId,
InternalCompletableFuture future) |
public void countDownCompletionLatch(int countDownLatchId)
countDownCompletionLatch
in interface CacheSyncListenerCompleter
public void deregisterCompletionLatch(Integer countDownLatchId)
public Integer registerCompletionLatch(int count)
public void waitCompletionLatch(Integer countDownLatchId, InternalCompletableFuture future) throws ExecutionException
ExecutionException
public void waitCompletionLatch(Integer countDownLatchId) throws ExecutionException
ExecutionException
public void waitCompletionLatch(Integer countDownLatchId, int offset) throws ExecutionException
ExecutionException
protected abstract void awaitLatch(CountDownLatch countDownLatch, InternalCompletableFuture future) throws ExecutionException
ExecutionException
public void putListenerIfAbsent(javax.cache.configuration.CacheEntryListenerConfiguration configuration, UUID regId)
public UUID removeListener(javax.cache.configuration.CacheEntryListenerConfiguration configuration)
public UUID getListenerId(javax.cache.configuration.CacheEntryListenerConfiguration configuration)
public void clearListeners()
public Collection<UUID> getListenersIds(boolean sync)
Copyright © 2019 Hazelcast, Inc.. All rights reserved.