net.spy.memcached.internal
Class BulkGetFuture<T>

java.lang.Object
  extended by net.spy.memcached.internal.BulkGetFuture<T>
Type Parameters:
T - types of objects returned from the GET
All Implemented Interfaces:
java.util.concurrent.Future<java.util.Map<java.lang.String,T>>

public class BulkGetFuture<T>
extends java.lang.Object
implements java.util.concurrent.Future<java.util.Map<java.lang.String,T>>

Future for handling results from bulk gets. Not intended for general use.


Constructor Summary
BulkGetFuture(java.util.Map<java.lang.String,java.util.concurrent.Future<T>> m, java.util.Collection<Operation> getOps, java.util.concurrent.CountDownLatch l)
           
 
Method Summary
 boolean cancel(boolean ign)
           
 java.util.Map<java.lang.String,T> get()
           
 java.util.Map<java.lang.String,T> get(long timeout, java.util.concurrent.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

BulkGetFuture

public BulkGetFuture(java.util.Map<java.lang.String,java.util.concurrent.Future<T>> m,
                     java.util.Collection<Operation> getOps,
                     java.util.concurrent.CountDownLatch l)
Method Detail

cancel

public boolean cancel(boolean ign)
Specified by:
cancel in interface java.util.concurrent.Future<java.util.Map<java.lang.String,T>>

get

public java.util.Map<java.lang.String,T> get()
                                      throws java.lang.InterruptedException,
                                             java.util.concurrent.ExecutionException
Specified by:
get in interface java.util.concurrent.Future<java.util.Map<java.lang.String,T>>
Throws:
java.lang.InterruptedException
java.util.concurrent.ExecutionException

get

public java.util.Map<java.lang.String,T> get(long timeout,
                                             java.util.concurrent.TimeUnit unit)
                                      throws java.lang.InterruptedException,
                                             java.util.concurrent.ExecutionException,
                                             java.util.concurrent.TimeoutException
Specified by:
get in interface java.util.concurrent.Future<java.util.Map<java.lang.String,T>>
Throws:
java.lang.InterruptedException
java.util.concurrent.ExecutionException
java.util.concurrent.TimeoutException

isCancelled

public boolean isCancelled()
Specified by:
isCancelled in interface java.util.concurrent.Future<java.util.Map<java.lang.String,T>>

isDone

public boolean isDone()
Specified by:
isDone in interface java.util.concurrent.Future<java.util.Map<java.lang.String,T>>