Searched refs:FutureTask (Results 1 - 10 of 10) sorted by relevance

/libcore/luni/src/main/java/java/util/concurrent/
H A DExecutorCompletionService.java83 * FutureTask extension to enqueue upon completion.
85 private static class QueueingFuture<V> extends FutureTask<Void> {
99 return new FutureTask<V>(task);
106 return new FutureTask<V>(task, result);
H A DFutureTask.java22 * <p>A {@code FutureTask} can be used to wrap a {@link Callable} or
23 * {@link Runnable} object. Because {@code FutureTask} implements
24 * {@code Runnable}, a {@code FutureTask} can be submitted to an
33 * @param <V> The result type returned by this FutureTask's {@code get} methods
35 public class FutureTask<V> implements RunnableFuture<V> { class in inherits:RunnableFuture
98 * Creates a {@code FutureTask} that will, upon running, execute the
104 public FutureTask(Callable<V> callable) { method in class:FutureTask
112 * Creates a {@code FutureTask} that will, upon running, execute the
120 * {@code Future<?> f = new FutureTask<Void>(runnable, null)}
123 public FutureTask(Runnabl method in class:FutureTask
[all...]
H A DAbstractExecutorService.java21 * to the {@link FutureTask} class provided in this package. For example,
26 * {@code FutureTask}.
30 * a {@code CustomTask} class instead of the default {@code FutureTask}:
64 return new FutureTask<T>(runnable, value);
79 return new FutureTask<T>(callable);
H A DScheduledThreadPoolExecutor.java78 * {@link FutureTask}. However, this may be modified or replaced using
153 extends FutureTask<V> implements RunnableScheduledFuture<V> {
265 * Overrides FutureTask version so as to reset/requeue if periodic.
/libcore/jsr166-tests/src/test/java/jsr166/
H A DFutureTaskTest.java25 import java.util.concurrent.FutureTask;
95 if (f instanceof FutureTask) {
96 FutureTask ft = (FutureTask<?>) f;
169 static class PublicFutureTask extends FutureTask {
240 new FutureTask(null);
250 new FutureTask(null, Boolean.TRUE);
726 final FutureTask task = new FutureTask(new NoOpCallable());
755 final FutureTask tas
[all...]
H A DExecutorCompletionServiceTest.java19 import java.util.concurrent.FutureTask;
163 class MyCallableFuture<V> extends FutureTask<V> {
194 class MyRunnableFuture<V> extends FutureTask<V> {
H A DThreadPoolExecutorSubclassTest.java25 import java.util.concurrent.FutureTask;
667 FutureTask[] tasks = new FutureTask[5];
676 tasks[i] = new FutureTask(task);
733 FutureTask[] tasks = new FutureTask[5];
741 tasks[i] = new FutureTask(task);
H A DThreadPoolExecutorTest.java26 import java.util.concurrent.FutureTask;
552 FutureTask[] tasks = new FutureTask[5];
561 tasks[i] = new FutureTask(task);
618 FutureTask[] tasks = new FutureTask[5];
626 tasks[i] = new FutureTask(task);
/libcore/luni/src/test/java/libcore/net/
H A DNetworkSecurityPolicyTest.java32 import java.util.concurrent.FutureTask;
239 private final FutureTask<byte[]> mFirstChunkReceivedFuture;
255 mFirstChunkReceivedFuture = new FutureTask<byte[]>(new Callable<byte[]>() {
/libcore/
H A Dnon_openjdk_java_files.mk120 luni/src/main/java/java/util/concurrent/FutureTask.java \

Completed in 92 milliseconds