com.hazelcast.spi.impl.operationparker

Interface OperationParker

All Known Implementing Classes:

OperationParkerImpl

public interface OperationParker

A service to park/unpark BlockingOperation. E.g. to implement a Lock.lock() or Condition.await().

Field Summary

Fields

Modifier and Type	Field and Description
static String	SERVICE_NAME

Method Summary

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.

Field Detail

SERVICE_NAME

static final String SERVICE_NAME

See Also:

Constant Field Values

Method Detail

park

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(). 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.

Parameters:

op - operation which will wait for notification

unpark

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. 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.

Parameters:

notifier - operation which will unpark a corresponding waiting operation

cancelParkedOperations

void cancelParkedOperations(String serviceName,
                            Object objectId,
                            Throwable cause)