org.opendaylight.vtn.manager.internal.util.concurrent

Class FutureCallbackTask<T>

java.lang.Object

org.opendaylight.vtn.manager.internal.util.concurrent.FutureCallbackTask<T>

Type Parameters:

T - The type of the object returned by the future.

All Implemented Interfaces:

Runnable

public final class FutureCallbackTask<T>
extends Object
implements Runnable

FutureCallbackTask is an executable task that invokes FutureCallback instance when an non-listenable future completes.

Constructor Summary

Constructors

Constructor and Description
FutureCallbackTask(Future<T> f, com.google.common.util.concurrent.FutureCallback<? super T> cb, Timer t) Construct a new instance with specifying 10 as the number of pollings.
FutureCallbackTask(Future<T> f, com.google.common.util.concurrent.FutureCallback<? super T> cb, Timer t, int npolls) Construct a new instance.

Method Summary

Modifier and Type	Method and Description
int	getMaxPolls() Return the maximum number of future pollings.
void	run() Wait for the completion of the future on a thread.

Methods inherited from class java.lang.Object

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

Constructor Detail

FutureCallbackTask

public FutureCallbackTask(Future<T> f,
                          com.google.common.util.concurrent.FutureCallback<? super T> cb,
                          Timer t)

Construct a new instance with specifying 10 as the number of pollings.

Parameters:

f - A future to wait for completion.

cb - A future callback to be invoked.

t - A timer used for polling.

FutureCallbackTask

public FutureCallbackTask(Future<T> f,
                          com.google.common.util.concurrent.FutureCallback<? super T> cb,
                          Timer t,
                          int npolls)

Construct a new instance.

Parameters:

f - A future to wait for completion.

cb - A future callback to be invoked.

t - A timer used for polling.

npolls - The maximum number of pollings.

Method Detail

getMaxPolls

public int getMaxPolls()

Return the maximum number of future pollings.

Returns:

The maxumum number of pollings.

run

public void run()

Wait for the completion of the future on a thread.

Specified by:

run in interface Runnable