Home
last modified time | relevance | path

Searched refs:FutureTask (Results 1 – 19 of 19) sorted by relevance

/libcore/ojluni/annotations/hiddenapi/java/util/concurrent/
DFutureTask.java41 public class FutureTask<V> implements java.util.concurrent.RunnableFuture<V> { class
43 public FutureTask(java.util.concurrent.Callable<V> callable) { in FutureTask() method in FutureTask
47 public FutureTask(java.lang.Runnable runnable, V result) { in FutureTask() method in FutureTask
109 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;
/libcore/luni/src/test/java/libcore/java/util/concurrent/
DFutureTaskTest.java23 import java.util.concurrent.FutureTask;
39 FutureTask task = new FutureTask(callable); in testRecursiveToString()
45 static class TestCallable extends AtomicReference<FutureTask> implements Callable<Integer> {
/libcore/jsr166-tests/src/test/java/jsr166/
DFutureTaskTest.java25 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 …]
DExecutorCompletionServiceTest.java19 import java.util.concurrent.FutureTask;
163 class MyCallableFuture<V> extends FutureTask<V> { in testNewTaskForCallable()
194 class MyRunnableFuture<V> extends FutureTask<V> { in testNewTaskForRunnable()
DThreadPoolExecutorTest.java26 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()
DThreadPoolExecutorSubclassTest.java25 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()
/libcore/ojluni/src/test/java/util/concurrent/tck/
DFutureTaskTest.java51 import java.util.concurrent.FutureTask;
118 if (f instanceof FutureTask) { in checkIsRunning()
119 FutureTask ft = (FutureTask<?>) f; in checkIsRunning()
192 static class PublicFutureTask extends FutureTask {
263 new FutureTask(null); in testConstructor()
273 new FutureTask(null, Boolean.TRUE); in testConstructor2()
749 final FutureTask task = new FutureTask(new NoOpCallable()); in testGet_interruptible()
778 final FutureTask task = new FutureTask(new NoOpCallable()); in testTimedGet_interruptible()
806 FutureTask task = new FutureTask(new NoOpCallable()); in testGet_TimeoutException()
820 FutureTask task = new FutureTask(new NoOpCallable()); in testGet_NullTimeUnit()
[all …]
DExecutorCompletionServiceTest.java47 import java.util.concurrent.FutureTask;
224 class MyCallableFuture<V> extends FutureTask<V> { in testNewTaskForCallable()
254 class MyRunnableFuture<V> extends FutureTask<V> { in testNewTaskForRunnable()
DThreadPoolExecutorTest.java52 import java.util.concurrent.FutureTask;
574 FutureTask[] tasks = new FutureTask[5]; in testGetQueue()
583 tasks[i] = new FutureTask(task); in testGetQueue()
640 FutureTask[] tasks = new FutureTask[5]; in testPurge()
648 tasks[i] = new FutureTask(task); in testPurge()
DThreadPoolExecutorSubclassTest.java50 import java.util.concurrent.FutureTask;
689 FutureTask[] tasks = new FutureTask[5]; in testGetQueue()
698 tasks[i] = new FutureTask(task); in testGetQueue()
755 FutureTask[] tasks = new FutureTask[5]; in testPurge()
763 tasks[i] = new FutureTask(task); in testPurge()
/libcore/ojluni/src/main/java/java/util/concurrent/
DFutureTask.java66 public class FutureTask<V> implements RunnableFuture<V> { class
132 public FutureTask(Callable<V> callable) { in FutureTask() method in FutureTask
151 public FutureTask(Runnable runnable, V result) { in FutureTask() method in FutureTask
530 STATE = l.findVarHandle(FutureTask.class, "state", int.class);
531 RUNNER = l.findVarHandle(FutureTask.class, "runner", Thread.class);
532 WAITERS = l.findVarHandle(FutureTask.class, "waiters", WaitNode.class);
DExecutorCompletionService.java111 private static class QueueingFuture<V> extends FutureTask<Void> {
125 return new FutureTask<V>(task); in newTaskFor()
132 return new FutureTask<V>(task, result); in newTaskFor()
DAbstractExecutorService.java98 return new FutureTask<T>(runnable, value); in newTaskFor()
113 return new FutureTask<T>(callable); in newTaskFor()
DScheduledThreadPoolExecutor.java189 extends FutureTask<V> implements RunnableScheduledFuture<V> {
/libcore/luni/src/test/java/libcore/java/lang/
DProcessBuilderTest.java38 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()
/libcore/expectations/
Dknownfailures.txt35 "java.util.concurrent.FutureTask.Throw",
/libcore/
Dopenjdk_java_files.bp1006 "ojluni/src/main/java/java/util/concurrent/FutureTask.java",
DEXPECTED_UPSTREAM1057 …n/java/java/util/concurrent/FutureTask.java,jdk17u/jdk-17.0.6-ga,src/java.base/share/classes/java/…
/libcore/api/
Dcurrent.txt16074 public class FutureTask<V> implements java.util.concurrent.RunnableFuture<V> {
16075 ctor public FutureTask(java.util.concurrent.Callable<V>);
16076 ctor public FutureTask(Runnable, V);