Searched refs:FutureTask (Results 1 – 12 of 12) sorted by relevance
41 public class FutureTask<V> implements java.util.concurrent.RunnableFuture<V> { class43 public FutureTask(java.util.concurrent.Callable<V> callable) { in FutureTask() method in FutureTask47 public FutureTask(java.lang.Runnable runnable, V result) { in FutureTask() method in FutureTask109 private void removeWaiter(java.util.concurrent.FutureTask.WaitNode node) { in removeWaiter()163 private volatile java.util.concurrent.FutureTask.WaitNode waiters;172 volatile java.util.concurrent.FutureTask.WaitNode next;
25 import java.util.concurrent.FutureTask;95 if (f instanceof FutureTask) { in checkIsRunning()96 FutureTask ft = (FutureTask<?>) f; in checkIsRunning()169 static class PublicFutureTask extends FutureTask {240 new FutureTask(null); in testConstructor()250 new FutureTask(null, Boolean.TRUE); in testConstructor2()726 final FutureTask task = new FutureTask(new NoOpCallable()); in testGet_interruptible()755 final FutureTask task = new FutureTask(new NoOpCallable()); in testTimedGet_interruptible()783 FutureTask task = new FutureTask(new NoOpCallable()); in testGet_TimeoutException()797 FutureTask task = new FutureTask(new NoOpCallable()); in testGet_NullTimeUnit()[all …]
19 import java.util.concurrent.FutureTask;163 class MyCallableFuture<V> extends FutureTask<V> { in testNewTaskForCallable()194 class MyRunnableFuture<V> extends FutureTask<V> { in testNewTaskForRunnable()
26 import java.util.concurrent.FutureTask;552 FutureTask[] tasks = new FutureTask[5]; in testGetQueue()561 tasks[i] = new FutureTask(task); in testGetQueue()618 FutureTask[] tasks = new FutureTask[5]; in testPurge()626 tasks[i] = new FutureTask(task); in testPurge()
25 import java.util.concurrent.FutureTask;667 FutureTask[] tasks = new FutureTask[5]; in testGetQueue()676 tasks[i] = new FutureTask(task); in testGetQueue()733 FutureTask[] tasks = new FutureTask[5]; in testPurge()741 tasks[i] = new FutureTask(task); in testPurge()
64 public class FutureTask<V> implements RunnableFuture<V> { class133 public FutureTask(Callable<V> callable) { in FutureTask() method in FutureTask152 public FutureTask(Runnable runnable, V result) { in FutureTask() method in FutureTask494 (FutureTask.class.getDeclaredField("state"));496 (FutureTask.class.getDeclaredField("runner"));498 (FutureTask.class.getDeclaredField("waiters"));
114 private static class QueueingFuture<V> extends FutureTask<Void> {128 return new FutureTask<V>(task); in newTaskFor()135 return new FutureTask<V>(task, result); in newTaskFor()
93 return new FutureTask<T>(runnable, value); in newTaskFor()108 return new FutureTask<T>(callable); in newTaskFor()
182 extends FutureTask<V> implements RunnableScheduledFuture<V> {
38 import java.util.concurrent.FutureTask;549 static FutureTask<String> asyncRead(final InputStream inputStream) { in asyncRead()550 final FutureTask<String> result = new FutureTask<>(() -> readAsString(inputStream)); in asyncRead()
35 "java.util.concurrent.FutureTask.Throw",
957 "ojluni/src/main/java/java/util/concurrent/FutureTask.java",