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
ConstructorDescriptionCreate a newProgressiveClientFuture
instance with no assignedClientSynchronization
.ProgressiveClientFuture
(ClientSynchronization<V> synchronization) Create a newProgressiveClientFuture
instance 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 newProgressiveClientFuture
instance with no assignedClientSynchronization
. -
ProgressiveClientFuture
Create a newProgressiveClientFuture
instance with the assignedClientSynchronization
.- Parameters:
synchronization
- theClientSynchronization
that should be notified upon completion of this future.
-
-
Method Details
-
get
public V get(long amount, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException - Specified by:
get
in interfaceFuture<V>
- Specified by:
get
in classClientFuture<V>
- Throws:
InterruptedException
ExecutionException
TimeoutException
-
get
- Specified by:
get
in interfaceFuture<V>
- Specified by:
get
in classClientFuture<V>
- Throws:
InterruptedException
ExecutionException
-