Package org.apache.qpid.protonj2.client.futures

Class ProgressiveClientFuture<V>

java.lang.Object

org.apache.qpid.protonj2.client.futures.ClientFuture<V>

org.apache.qpid.protonj2.client.futures.ProgressiveClientFuture<V>

Type Parameters:

V - The type that result from completion of this Future

All Implemented Interfaces:

Future<V>, AsyncResult<V>

public class ProgressiveClientFuture<V>
extends ClientFuture<V>

An optimized version of a ClientFuture that makes use of spin waits and other methods of reacting to asynchronous completion in a more timely manner.

Field Summary

Fields inherited from class org.apache.qpid.protonj2.client.futures.ClientFuture

CANCELLED, COMPLETING, error, FAILURE, INCOMPLETE, result, STATE_FIELD_UPDATER, SUCCESS, synchronization, waiting

Constructor Summary

Constructors

Constructor	Description
ProgressiveClientFuture()	Create a new ProgressiveClientFuture instance with no assigned ClientSynchronization.
ProgressiveClientFuture(ClientSynchronization<V> synchronization)	Create a new ProgressiveClientFuture instance with the assigned ClientSynchronization.

Method Summary

Modifier and Type	Method	Description
V	get()
V	get(long amount, TimeUnit unit)

Methods inherited from class org.apache.qpid.protonj2.client.futures.ClientFuture

cancel, complete, failed, getResult, getState, isCancelled, isComplete, isDone, isFailed, isNotComplete, tryCancelTask

Methods inherited from class java.lang.Object

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

Constructor Detail

ProgressiveClientFuture

public ProgressiveClientFuture()

Create a new ProgressiveClientFuture instance with no assigned ClientSynchronization.

ProgressiveClientFuture

public ProgressiveClientFuture(ClientSynchronization<V> synchronization)

Create a new ProgressiveClientFuture instance with the assigned ClientSynchronization.

Parameters:

synchronization - the ClientSynchronization that should be notified upon completion of this future.

Method Detail

get

public V get(long amount,
             TimeUnit unit)
      throws InterruptedException,
             ExecutionException,
             TimeoutException

Specified by:

get in interface Future<V>

Specified by:

get in class ClientFuture<V>

Throws:

InterruptedException

ExecutionException

TimeoutException

get

public V get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<V>

Specified by:

get in class ClientFuture<V>

Throws:

InterruptedException

ExecutionException