/openjdk7/jdk/src/share/classes/java/util/concurrent/ |
H A D | CompletionService.java | 64 * Submits a value-returning task for execution and returns a Future 69 * @return a Future representing pending completion of the task 74 Future<V> submit(Callable<V> task); 77 * Submits a Runnable task for execution and returns a Future 83 * @return a Future representing pending completion of the task, 90 Future<V> submit(Runnable task, V result); 93 * Retrieves and removes the Future representing the next 96 * @return the Future representing the next completed task 99 Future<V> take() throws InterruptedException; 103 * Retrieves and removes the Future representin [all...] |
H A D | ScheduledFuture.java | 45 * @param <V> The result type returned by this Future 47 public interface ScheduledFuture<V> extends Delayed, Future<V> {
|
H A D | RunnableFuture.java | 39 * A {@link Future} that is {@link Runnable}. Successful execution of 40 * the <tt>run</tt> method causes completion of the <tt>Future</tt> 46 * @param <V> The result type returned by this Future's <tt>get</tt> method 48 public interface RunnableFuture<V> extends Runnable, Future<V> { 50 * Sets this Future to the result of its computation
|
H A D | ExecutorCompletionService.java | 82 * List<Future<Result>> futures 83 * = new ArrayList<Future<Result>>(n); 99 * for (Future<Result> f : futures) 110 private final BlockingQueue<Future<V>> completionQueue; 121 private final Future<V> task; 152 this.completionQueue = new LinkedBlockingQueue<Future<V>>(); 169 BlockingQueue<Future<V>> completionQueue) { 178 public Future<V> submit(Callable<V> task) { 185 public Future<V> submit(Runnable task, V result) { 192 public Future< [all...] |
H A D | ExecutorService.java | 44 * methods that can produce a {@link Future} for tracking progress of 59 * Executor#execute} by creating and returning a {@link Future} that 136 * result is retrieved via {@code Future.get()}. 220 * Future representing the pending results of the task. The 221 * Future's <tt>get</tt> method will return the task's result upon 235 * @return a Future representing pending completion of the task 240 <T> Future<T> submit(Callable<T> task); 243 * Submits a Runnable task for execution and returns a Future 244 * representing that task. The Future's <tt>get</tt> method will 249 * @return a Future representin [all...] |
H A D | AbstractExecutorService.java | 80 * underlying runnable and which, as a <tt>Future</tt>, will yield 94 * underlying callable and which, as a <tt>Future</tt>, will yield 107 public Future<?> submit(Runnable task) { 118 public <T> Future<T> submit(Runnable task, T result) { 129 public <T> Future<T> submit(Callable<T> task) { 147 List<Future<T>> futures= new ArrayList<Future<T>>(ntasks); 170 Future<T> f = ecs.poll(); 207 for (Future<T> f : futures) 228 public <T> List<Future< [all...] |
H A D | Future.java | 39 * A <tt>Future</tt> represents the result of an asynchronous 48 * If you would like to use a <tt>Future</tt> for the sake 50 * declare types of the form {@code Future<?>} and 63 * Future<String> future 75 * The {@link FutureTask} class is an implementation of <tt>Future</tt> that 88 * actions following the corresponding {@code Future.get()} in another thread. 94 * @param <V> The result type returned by this Future's <tt>get</tt> method 96 public interface Future<V> { interface
|
/openjdk7/jaxws/src/share/jaxws_classes/javax/xml/ws/ |
H A D | Response.java | 29 import java.util.concurrent.Future; 44 public interface Response<T> extends Future<T> {
|
H A D | Dispatch.java | 28 import java.util.concurrent.Future; 88 * @return A <code>Future</code> object that may be used to check the status 91 * <code>Future<?>.get()</code> is implementation dependent 96 public Future<?> invokeAsync(T msg, AsyncHandler<T> handler);
|
/openjdk7/jdk/src/share/classes/java/nio/channels/ |
H A D | AsynchronousByteChannel.java | 29 import java.util.concurrent.Future; 118 * of specifying a completion handler, this method returns a {@code Future} 119 * representing the pending result. The {@code Future}'s {@link Future#get() 126 * @return A Future representing the result of the operation 134 Future<Integer> read(ByteBuffer dst); 195 * of specifying a completion handler, this method returns a {@code Future} 196 * representing the pending result. The {@code Future}'s {@link Future#get() 202 * @return A Future representin [all...] |
H A D | AsynchronousChannel.java | 29 import java.util.concurrent.Future; // javadoc 36 * <li><pre>{@link Future}<V> <em>operation</em>(<em>...</em>)</pre></li> 48 * <p> In the first form, the methods defined by the {@link Future Future} 66 * <p> The {@code Future} interface defines the {@link Future#cancel cancel} 83 * <p> Where the {@link Future#cancel cancel} method is invoked with the {@code
|
H A D | AsynchronousFileChannel.java | 33 import java.util.concurrent.Future; 54 * asynchronous operations, returning a {@link Future} to represent the pending 55 * result of the operation. The {@code Future} may be used to check if the 499 * method returns a {@code Future} representing the pending result. The 500 * {@code Future}'s {@link Future#get() get} method returns the {@link 515 * @return a {@code Future} object representing the pending result 527 public abstract Future<FileLock> lock(long position, long size, boolean shared); 533 * channel's file. The method returns a {@code Future} representing the 534 * pending result of the operation. The {@code Future}' [all...] |
H A D | AsynchronousSocketChannel.java | 30 import java.util.concurrent.Future; 324 * Future} representing the pending result. The {@code Future}'s {@link 325 * Future#get() get} method returns {@code null} on successful completion. 330 * @return A {@code Future} object representing the pending result 344 public abstract Future<Void> connect(SocketAddress remote); 417 public abstract Future<Integer> read(ByteBuffer dst); 569 public abstract Future<Integer> write(ByteBuffer src);
|
H A D | AsynchronousServerSocketChannel.java | 31 import java.util.concurrent.Future; 288 * returns a {@code Future} representing the pending result. The {@code 289 * Future}'s {@link Future#get() get} method returns the {@link 292 * @return a {@code Future} object representing the pending result 299 public abstract Future<AsynchronousSocketChannel> accept();
|
/openjdk7/corba/src/share/classes/com/sun/corba/se/impl/orbutil/closure/ |
H A D | Future.java | 30 public class Future implements Closure { class in inherits:Closure 35 public Future( Closure value ) method in class:Future
|
/openjdk7/corba/src/share/classes/com/sun/corba/se/spi/orbutil/closure/ |
H A D | ClosureFactory.java | 29 import com.sun.corba.se.impl.orbutil.closure.Future ; 41 return new Future( value ) ;
|
/openjdk7/jdk/test/java/nio/channels/AsynchronousSocketChannel/ |
H A D | DieBeforeComplete.java | 51 Future<AsynchronousSocketChannel> r1 = 53 public Future<AsynchronousSocketChannel> run() { 65 Future<Integer> r2 = initiateAndDie(new Task<Integer>() { 66 public Future<Integer> run() { 80 Future<Integer> r3; 84 public Future<Integer> run() { 116 Future<T> run(); 119 static <T> Future<T> initiateAndDie(final Task<T> task) { 120 final AtomicReference<Future<T>> result = new AtomicReference<Future< [all...] |
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/util/ |
H A D | CompletedFuture.java | 29 import java.util.concurrent.Future; 33 * {@link Future} implementation that obtains an already available value. 38 public class CompletedFuture<T> implements Future<T> {
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/client/sei/ |
H A D | CallbackMethodHandler.java | 31 import java.util.concurrent.Future; 50 Future<?> invoke(Object proxy, Object[] args) throws WebServiceException {
|
/openjdk7/jdk/src/share/classes/sun/nio/ch/ |
H A D | AsynchronousFileChannelImpl.java | 31 import java.util.concurrent.Future; 106 abstract <A> Future<FileLock> implLock(long position, 113 public final Future<FileLock> lock(long position, 211 abstract <A> Future<Integer> implRead(ByteBuffer dst, 217 public final Future<Integer> read(ByteBuffer dst, long position) { 232 abstract <A> Future<Integer> implWrite(ByteBuffer src, 239 public final Future<Integer> write(ByteBuffer src, long position) {
|
H A D | CompletedFuture.java | 28 import java.util.concurrent.Future; 34 * A Future representing the result of an I/O operation that has already 38 final class CompletedFuture<V> implements Future<V> {
|
/openjdk7/jdk/test/java/nio/channels/SelectionKey/ |
H A D | RacyRegister.java | 46 Future<Void> result = pool.submit(new Callable<Void>() {
|
/openjdk7/jdk/test/java/util/concurrent/BlockingQueue/ |
H A D | CancelledProducerConsumerLoops.java | 82 Future<?>[] prods = new Future<?>[npairs]; 83 Future<?>[] cons = new Future<?>[npairs];
|
/openjdk7/jdk/test/java/util/concurrent/ExecutorService/ |
H A D | Invoke.java | 71 List<Future<Long>> futures = fixed.invokeAll(tasks); 76 for (Future<Long> future : futures) gauss += future.get();
|
/openjdk7/jdk/src/share/classes/sun/rmi/transport/ |
H A D | DGCAckHandler.java | 35 import java.util.concurrent.Future; 82 private Future<?> task = null;
|