org.infinispan.util.concurrent
Class AggregatingNotifyingFutureImpl<T>
java.lang.Object
org.infinispan.util.concurrent.BaseNotifyingFuture<T>
org.infinispan.util.concurrent.NotifyingFutureImpl<T>
org.infinispan.util.concurrent.AggregatingNotifyingFutureImpl<T>
- All Implemented Interfaces:
- Future<T>, NotifyingFuture<T>, NotifyingNotifiableFuture<T>
public class AggregatingNotifyingFutureImpl<T>
- extends NotifyingFutureImpl<T>
For use with > 1 underlying network future
- Since:
- 4.0
- Author:
- Manik Surtani
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AggregatingNotifyingFutureImpl
public AggregatingNotifyingFutureImpl(T actualReturnValue,
int maxFutures)
setNetworkFuture
public void setNetworkFuture(Future<T> future)
- Specified by:
setNetworkFuture
in interface NotifyingNotifiableFuture<T>
- Overrides:
setNetworkFuture
in class NotifyingFutureImpl<T>
cancel
public boolean cancel(boolean mayInterruptIfRunning)
- Specified by:
cancel
in interface Future<T>
- Overrides:
cancel
in class NotifyingFutureImpl<T>
isCancelled
public boolean isCancelled()
- Specified by:
isCancelled
in interface Future<T>
- Overrides:
isCancelled
in class NotifyingFutureImpl<T>
isDone
public boolean isDone()
- Specified by:
isDone
in interface Future<T>
- Overrides:
isDone
in class NotifyingFutureImpl<T>
get
public T get()
throws InterruptedException,
ExecutionException
- Specified by:
get
in interface Future<T>
- Overrides:
get
in class NotifyingFutureImpl<T>
- Throws:
InterruptedException
ExecutionException
get
public T get(long timeout,
TimeUnit unit)
throws InterruptedException,
ExecutionException,
TimeoutException
- Specified by:
get
in interface Future<T>
- Overrides:
get
in class NotifyingFutureImpl<T>
- Throws:
InterruptedException
ExecutionException
TimeoutException
notifyDone
public void notifyDone()
- Specified by:
notifyDone
in interface NotifyingNotifiableFuture<T>
- Overrides:
notifyDone
in class BaseNotifyingFuture<T>
Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.