public class WaitNotifyServiceImpl extends Object implements InternalWaitNotifyService
Constructor and Description |
---|
WaitNotifyServiceImpl(NodeEngineImpl nodeEngine) |
Modifier and Type | Method and Description |
---|---|
void |
await(WaitSupport waitSupport)
Causes the current operation to wait in WaitNotifyService until it is notified
by a
Notifier operation or timeout specified by
WaitSupport.getWaitTimeout() passes. |
void |
cancelWaitingOps(String serviceName,
Object objectId,
Throwable cause) |
int |
getAwaitQueueCount() |
int |
getTotalWaitingOperationCount() |
void |
notify(Notifier notifier)
Notifies the waiting
WaitSupport operation to wake-up and continue executing. |
void |
onClientDisconnected(String clientUuid) |
void |
onMemberLeft(MemberImpl leftMember) |
void |
onPartitionMigrate(Address thisAddress,
MigrationInfo migrationInfo) |
void |
reset() |
void |
shutdown() |
String |
toString() |
public WaitNotifyServiceImpl(NodeEngineImpl nodeEngine)
public void await(WaitSupport waitSupport)
WaitNotifyService
Notifier
operation or timeout specified by
WaitSupport.getWaitTimeout()
passes.
WaitSupport
operation will be registered using WaitNotifyKey
returned from method WaitSupport.getWaitKey()
.
When operation is notified, it's re-executed by related scheduled mechanism.
If wait time-outs, WaitSupport.onWaitExpire()
method is called.
This method should be called in the thread executes the actual WaitSupport
operation.await
in interface WaitNotifyService
waitSupport
- operation which will wait for notificationpublic void notify(Notifier notifier)
WaitNotifyService
WaitSupport
operation to wake-up and continue executing.
A waiting operation registered with the Notifier.getNotifiedKey()
will be notified and deregistered.
This method has no effect if there isn't any operation registered
for related WaitNotifyKey
.
This method should be called in the thread executes the actual Notifier
operation.notify
in interface WaitNotifyService
notifier
- operation which will notify a corresponding waiting operationpublic int getAwaitQueueCount()
public int getTotalWaitingOperationCount()
public void onMemberLeft(MemberImpl leftMember)
public void onClientDisconnected(String clientUuid)
public void onPartitionMigrate(Address thisAddress, MigrationInfo migrationInfo)
public void cancelWaitingOps(String serviceName, Object objectId, Throwable cause)
cancelWaitingOps
in interface InternalWaitNotifyService
public void reset()
public void shutdown()
Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.