public interface OperationParker
Modifier and Type | Field and Description |
---|---|
static String |
SERVICE_NAME |
Modifier and Type | Method and Description |
---|---|
void |
cancelParkedOperations(String serviceName,
Object objectId,
Throwable cause) |
void |
park(BlockingOperation op)
Parks the Operation until it is unparked by a
unpark(Notifier) call or by a timeout specified by the
BlockingOperation.getWaitTimeout() . |
void |
unpark(Notifier notifier)
Unparks the parked
BlockingOperation operation by rescheduling it on the
OperationExecutor
A parked operation registered with the Notifier.getNotifiedKey() will be notified and deregistered. |
static final String SERVICE_NAME
void park(BlockingOperation op)
unpark(Notifier)
call or by a timeout specified by the
BlockingOperation.getWaitTimeout()
. After the BlockingOperation
is parked, this method returns;
it doesn't wait.
BlockingOperation
operation will be registered using WaitNotifyKey
returned from method BlockingOperation.getWaitKey()
.
If wait time-outs, BlockingOperation.onWaitExpire()
method is called.
This method should be called in the thread that executes the actual BlockingOperation
operation.op
- operation which will wait for notificationvoid unpark(Notifier notifier)
BlockingOperation
operation by rescheduling it on the
OperationExecutor
A parked 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 that executes the actual Notifier
operation.notifier
- operation which will unpark a corresponding waiting operationCopyright © 2019 Hazelcast, Inc.. All Rights Reserved.