Infinispan Distribution 5.2.6.Final-redhat-2

org.infinispan.util.concurrent
Class AggregatingNotifyingFutureImpl<T>

java.lang.Object
  extended by org.infinispan.util.concurrent.BaseNotifyingFuture<T>
      extended by org.infinispan.util.concurrent.NotifyingFutureImpl<T>
          extended by 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

Constructor Summary
AggregatingNotifyingFutureImpl(T actualReturnValue, int maxFutures)
           
 
Method Summary
 boolean cancel(boolean mayInterruptIfRunning)
           
 T get()
           
 T get(long timeout, TimeUnit unit)
           
 boolean isCancelled()
           
 boolean isDone()
           
 void notifyDone()
           
 void setNetworkFuture(Future<T> future)
           
 
Methods inherited from class org.infinispan.util.concurrent.BaseNotifyingFuture
attachListener
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.infinispan.util.concurrent.NotifyingFuture
attachListener
 

Constructor Detail

AggregatingNotifyingFutureImpl

public AggregatingNotifyingFutureImpl(T actualReturnValue,
                                      int maxFutures)
Method Detail

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>

Infinispan Distribution 5.2.6.Final-redhat-2

Copyright © 2013 JBoss, a division of Red Hat. All Rights Reserved.