com.hazelcast.client.util

Class ClientCancellableDelegatingFuture<V>

java.lang.Object

com.hazelcast.client.util.ClientDelegatingFuture<V>

com.hazelcast.client.util.ClientCancellableDelegatingFuture<V>

Type Parameters:

V - Type of returned object from the get method of this class.

All Implemented Interfaces:

ICompletableFuture<V>, Future<V>

Direct Known Subclasses:

ClientAddressCancellableDelegatingFuture, ClientPartitionCancellableDelegatingFuture

public abstract class ClientCancellableDelegatingFuture<V>
extends ClientDelegatingFuture<V>

An Abstract DelegatingFuture that can cancel a Runnable/Callable that is executed by an IExecutorService. It does this by sending a Cancellation Request to the remote owning member and then cancelling the running task.

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	cancelled
protected ClientContext	context
protected String	uuid

Constructor Summary

Constructors

Constructor and Description
ClientCancellableDelegatingFuture(ClientInvocationFuture future, ClientContext context, String uuid, V defaultValue, ClientMessageDecoder resultDecoder)

Method Summary

Methods

Modifier and Type	Method and Description
abstract boolean	cancel(boolean mayInterruptIfRunning)
boolean	isCancelled()
protected void	waitForRequestToBeSend()

Methods inherited from class com.hazelcast.client.util.ClientDelegatingFuture

andThen, andThen, andThenInternal, get, get, getFuture, getResponse, isDone, setDone, setError

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

context

protected final ClientContext context

uuid

protected final String uuid

cancelled

protected volatile boolean cancelled

Constructor Detail

ClientCancellableDelegatingFuture

public ClientCancellableDelegatingFuture(ClientInvocationFuture future,
                                 ClientContext context,
                                 String uuid,
                                 V defaultValue,
                                 ClientMessageDecoder resultDecoder)

Method Detail

cancel

public abstract boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<V>

Overrides:

cancel in class ClientDelegatingFuture<V>

waitForRequestToBeSend

protected void waitForRequestToBeSend()
                               throws InterruptedException

Throws:

InterruptedException

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<V>

Overrides:

isCancelled in class ClientDelegatingFuture<V>