com.allanbank.mongodb.connection

Class FutureCallback<V>

java.lang.Object

com.allanbank.mongodb.connection.FutureCallback<V>

Type Parameters:

V - The type for the set value.

All Implemented Interfaces:

Callback<V>, Future<V>

Direct Known Subclasses:

SecondsBehindCallback, ServerLatencyCallback

public class FutureCallback<V>
extends Object
implements Future<V>, Callback<V>

Implementation of a Callback and Future interfaces. Used to convert a Callback into a Future for returning to callers.

API Warning:

This class is NOT part of the drivers API. This class may be mutated in incompatible ways between any two releases of the driver.

Copyright ©:

2011-2012, Allanbank Consulting, Inc., All Rights Reserved

Constructor Summary

Constructors

Constructor and Description
FutureCallback() Create a new FutureCallback.

Method Summary

Methods

Modifier and Type	Method and Description
void	callback(V result) Called when the MongoDB operation has completed with the result of the operation.
boolean	cancel(boolean mayInterruptIfRunning)
void	exception(Throwable thrown) Called when the operation fails due to an exception.
V	get()
V	get(long timeout, TimeUnit unit)
boolean	isCancelled()
boolean	isDone()

Methods inherited from class java.lang.Object

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

Constructor Detail

FutureCallback

public FutureCallback()

Create a new FutureCallback.

Method Detail

callback

public void callback(V result)

Called when the MongoDB operation has completed with the result of the operation.

Sets the value for the future and triggers any pending get() to return.

Specified by:

callback in interface Callback<V>

Parameters:

result - The result of the operation.

See Also:

Callback.callback(V)

cancel

public boolean cancel(boolean mayInterruptIfRunning)

If not cancelled and the callback has not completed then cancels the future, triggers the return of any pending get() and returns true. Otherwise returns false. This does not stop the related MongoDB invocation.

Specified by:

cancel in interface Future<V>

See Also:

Future.cancel(boolean)

exception

public void exception(Throwable thrown)

Called when the operation fails due to an exception.

Sets the exception for the future and triggers any pending get() to throw a ExecutionException.

Specified by:

exception in interface Callback<V>

Parameters:

thrown - The thrown exception.

See Also:

Callback.exception(java.lang.Throwable)

get

public V get()
      throws InterruptedException,
             ExecutionException

Returns the value set via the Callback.

Specified by:

get in interface Future<V>

Throws:

InterruptedException

ExecutionException

See Also:

Future.get()

get

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

Returns the value set via the Callback.

Specified by:

get in interface Future<V>

Throws:

InterruptedException

ExecutionException

TimeoutException

See Also:

Future.get(long, TimeUnit)

isCancelled

public boolean isCancelled()

Returns true if cancel(boolean) has been called.

Specified by:

isCancelled in interface Future<V>

See Also:

Future.isCancelled()

isDone

public boolean isDone()

True if a value has been set via the the Callback interface or the Future has been cancelled.

Specified by:

isDone in interface Future<V>

See Also:

Future.isDone()