Searched refs:Future (Results 1 - 25 of 63) sorted by relevance

123

/openjdk7/jdk/src/share/classes/java/util/concurrent/
H A DCompletionService.java64 * 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 DScheduledFuture.java45 * @param <V> The result type returned by this Future
47 public interface ScheduledFuture<V> extends Delayed, Future<V> {
H A DRunnableFuture.java39 * 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 DExecutorCompletionService.java82 * 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 DExecutorService.java44 * 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 DAbstractExecutorService.java80 * 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 DFuture.java39 * 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 DResponse.java29 import java.util.concurrent.Future;
44 public interface Response<T> extends Future<T> {
H A DDispatch.java28 import java.util.concurrent.Future;
88 * @return A <code>Future</code> object that may be used to check the status
91 * <code>Future&lt;?>.get()</code> is implementation dependent
96 public Future<?> invokeAsync(T msg, AsyncHandler<T> handler);
/openjdk7/jdk/src/share/classes/java/nio/channels/
H A DAsynchronousByteChannel.java29 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 DAsynchronousChannel.java29 import java.util.concurrent.Future; // javadoc
36 * <li><pre>{@link Future}&lt;V&gt; <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 DAsynchronousFileChannel.java33 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 DAsynchronousSocketChannel.java30 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 DAsynchronousServerSocketChannel.java31 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 DFuture.java30 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 DClosureFactory.java29 import com.sun.corba.se.impl.orbutil.closure.Future ;
41 return new Future( value ) ;
/openjdk7/jdk/test/java/nio/channels/AsynchronousSocketChannel/
H A DDieBeforeComplete.java51 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 DCompletedFuture.java29 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 DCallbackMethodHandler.java31 import java.util.concurrent.Future;
50 Future<?> invoke(Object proxy, Object[] args) throws WebServiceException {
/openjdk7/jdk/src/share/classes/sun/nio/ch/
H A DAsynchronousFileChannelImpl.java31 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 DCompletedFuture.java28 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 DRacyRegister.java46 Future<Void> result = pool.submit(new Callable<Void>() {
/openjdk7/jdk/test/java/util/concurrent/BlockingQueue/
H A DCancelledProducerConsumerLoops.java82 Future<?>[] prods = new Future<?>[npairs];
83 Future<?>[] cons = new Future<?>[npairs];
/openjdk7/jdk/test/java/util/concurrent/ExecutorService/
H A DInvoke.java71 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 DDGCAckHandler.java35 import java.util.concurrent.Future;
82 private Future<?> task = null;

Completed in 61 milliseconds

123