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

Class ConservativeClientFuture<V>

java.lang.Object

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

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

Type Parameters:

V - The type that result from completion of this Future

All Implemented Interfaces:

Future<V>, AsyncResult<V>

public class ConservativeClientFuture<V>
extends ClientFuture<V>

A more conservative implementation of a ClientFuture that is better on some platforms or resource constrained hardware where high CPU usage can be more counter productive than other variants that might spin or otherwise avoid entry into states requiring thread signaling.

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
ConservativeClientFuture()	Create a new ConservativeClientFuture instance with no assigned ClientSynchronization.
ConservativeClientFuture(ClientSynchronization<V> synchronization)	Create a new ConservativeClientFuture 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 Details

ConservativeClientFuture

public ConservativeClientFuture()

Create a new ConservativeClientFuture instance with no assigned ClientSynchronization.

ConservativeClientFuture

public ConservativeClientFuture(ClientSynchronization<V> synchronization)

Create a new ConservativeClientFuture instance with the assigned ClientSynchronization.

Parameters:

synchronization - the ClientSynchronization 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 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