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>
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
ConstructorsConstructorDescriptionCreate a newProgressiveClientFutureinstance with no assignedClientSynchronization.ProgressiveClientFuture(ClientSynchronization<V> synchronization) Create a newProgressiveClientFutureinstance with the assignedClientSynchronization. -
Method Summary
Methods inherited from class org.apache.qpid.protonj2.client.futures.ClientFuture
cancel, complete, failed, getResult, getState, isCancelled, isComplete, isDone, isFailed, isNotComplete, tryCancelTask
-
Constructor Details
-
ProgressiveClientFuture
public ProgressiveClientFuture()Create a newProgressiveClientFutureinstance with no assignedClientSynchronization. -
ProgressiveClientFuture
Create a newProgressiveClientFutureinstance with the assignedClientSynchronization.- Parameters:
synchronization- theClientSynchronizationthat should be notified upon completion of this future.
-
-
Method Details
-
get
public V get(long amount, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException - Specified by:
getin interfaceFuture<V>- Specified by:
getin classClientFuture<V>- Throws:
InterruptedExceptionExecutionExceptionTimeoutException
-
get
- Specified by:
getin interfaceFuture<V>- Specified by:
getin classClientFuture<V>- Throws:
InterruptedExceptionExecutionException
-