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

Class BalancedClientFuture<V>

java.lang.Object

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

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

Type Parameters:

V - The type that result from completion of this Future

All Implemented Interfaces:

Future<V>, AsyncResult<V>

public class BalancedClientFuture<V>
extends ClientFuture<V>

A more balanced implementation of a ClientFuture that works better on some platforms such as windows where the thread park and atomic operations used by a more aggressive implementation could result in poor performance.

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

BalancedClientFuture

public BalancedClientFuture()

Create a new BalancedClientFuture instance with no assigned ClientSynchronization.

BalancedClientFuture

public BalancedClientFuture(ClientSynchronization<V> synchronization)

Create a new BalancedClientFuture 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