| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | FutureTaskTest.java | 259 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testIsDone() local
271 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testRunAndReset() local
287 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testRunAndResetAfterCancel() local
305 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testSet() local
322 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testSetException_get() local
352 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testCancelBeforeRun() local
369 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testCancelBeforeRun2() local
386 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testCancelAfterRun() local
401 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testCancelAfterRun2() local
417 final PublicFutureTask task = in testCancelInterrupt() local
[all …]
|
| D | ScheduledExecutorSubclassTest.java | 53 RunnableScheduledFuture<V> task; field in ScheduledExecutorSubclassTest.CustomTask
84 …rotected <V> RunnableScheduledFuture<V> decorateTask(Runnable r, RunnableScheduledFuture<V> task) { in decorateTask()
88 …ected <V> RunnableScheduledFuture<V> decorateTask(Callable<V> c, RunnableScheduledFuture<V> task) { in decorateTask()
113 final Runnable task = new CheckedRunnable() { in testExecute() local
128 Callable task = new CheckedCallable<Boolean>() { in testSchedule1() local
148 Runnable task = new CheckedRunnable() { in testSchedule3() local
168 Runnable task = new CheckedRunnable() { in testSchedule4() local
190 Runnable task = new CheckedRunnable() { in testSchedule5() local
221 final Runnable task = new CheckedRunnable() { in testFixedRateSequence() local
253 final Runnable task = new CheckedRunnable() { in testFixedDelaySequence() local
[all …]
|
| /libcore/ojluni/src/test/java/util/concurrent/tck/ |
| D | FutureTaskTest.java | 282 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testIsDone() local
294 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testRunAndReset() local
310 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testRunAndResetAfterCancel() local
328 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testSet() local
345 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testSetException_get() local
375 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testCancelBeforeRun() local
392 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testCancelBeforeRun2() local
409 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testCancelAfterRun() local
424 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testCancelAfterRun2() local
440 final PublicFutureTask task = in testCancelInterrupt() local
[all …]
|
| D | ScheduledExecutorSubclassTest.java | 77 private final RunnableScheduledFuture<V> task; field in ScheduledExecutorSubclassTest.CustomTask
79 CustomTask(RunnableScheduledFuture<V> task) { this.task = task; } in CustomTask()
108 …rotected <V> RunnableScheduledFuture<V> decorateTask(Runnable r, RunnableScheduledFuture<V> task) { in decorateTask()
112 …ected <V> RunnableScheduledFuture<V> decorateTask(Callable<V> c, RunnableScheduledFuture<V> task) { in decorateTask()
137 final Runnable task = new CheckedRunnable() { in testExecute() local
152 Callable task = new CheckedCallable<Boolean>() { in testSchedule1() local
172 Runnable task = new CheckedRunnable() { in testSchedule3() local
192 Runnable task = new CheckedRunnable() { in testSchedule4() local
214 Runnable task = new CheckedRunnable() { in testSchedule5() local
245 final Runnable task = new CheckedRunnable() { in testFixedRateSequence() local
[all …]
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | ExecutorCompletionService.java | 112 QueueingFuture(RunnableFuture<V> task, in QueueingFuture()
118 private final Future<V> task; field in ExecutorCompletionService.QueueingFuture
123 private RunnableFuture<V> newTaskFor(Callable<V> task) { in newTaskFor()
130 private RunnableFuture<V> newTaskFor(Runnable task, V result) { in newTaskFor()
181 public Future<V> submit(Callable<V> task) { in submit()
192 public Future<V> submit(Runnable task, V result) { in submit()
|
| D | CompletionService.java | 75 Future<V> submit(Callable<V> task); in submit()
91 Future<V> submit(Runnable task, V result); in submit()
|
| D | ExecutorService.java | 226 <T> Future<T> submit(Callable<T> task); in submit()
241 <T> Future<T> submit(Runnable task, T result); in submit()
254 Future<?> submit(Runnable task); in submit()
|
| D | AbstractExecutorService.java | 120 public Future<?> submit(Runnable task) { in submit()
131 public <T> Future<T> submit(Runnable task, T result) { in submit()
142 public <T> Future<T> submit(Callable<T> task) { in submit()
|
| D | Executors.java | 390 public static <T> Callable<T> callable(Runnable task, T result) { in callable()
403 public static Callable<Object> callable(Runnable task) { in callable()
|
| D | ScheduledThreadPoolExecutor.java | 319 boolean canRunInCurrentRunState(RunnableScheduledFuture<?> task) { in canRunInCurrentRunState()
343 private void delayedExecute(RunnableScheduledFuture<?> task) { in delayedExecute()
361 void reExecutePeriodic(RunnableScheduledFuture<?> task) { in reExecutePeriodic()
415 Runnable runnable, RunnableScheduledFuture<V> task) { in decorateTask()
432 Callable<V> callable, RunnableScheduledFuture<V> task) { in decorateTask()
721 public Future<?> submit(Runnable task) { in submit()
729 public <T> Future<T> submit(Runnable task, T result) { in submit()
737 public <T> Future<T> submit(Callable<T> task) { in submit()
|
| /libcore/ojluni/src/main/java/java/util/ |
| D | Timer.java | 209 public void schedule(TimerTask task, long delay) { in schedule()
226 public void schedule(TimerTask task, Date time) { in schedule()
262 public void schedule(TimerTask task, long delay, long period) { in schedule()
303 public void schedule(TimerTask task, Date firstTime, long period) { in schedule()
342 public void scheduleAtFixedRate(TimerTask task, long delay, long period) { in scheduleAtFixedRate()
385 public void scheduleAtFixedRate(TimerTask task, Date firstTime, in scheduleAtFixedRate()
405 private void sched(TimerTask task, long time, long period) { in sched()
539 TimerTask task; in mainLoop() local
|
| /libcore/ojluni/src/test/java/util/Timer/ |
| D | Args.java | 39 void schedule(final Timer t, final TimerTask task, final Date d) { in schedule()
46 void schedule(final Timer t, final TimerTask task, final Date d, final in schedule()
54 void scheduleAtFixedRate(final Timer t, final TimerTask task, final in scheduleAtFixedRate()
|
| D | DelayOverflow.java | 43 void scheduleNow(Timer timer, TimerTask task, int how) { in scheduleNow()
68 void checkScheduledExecutionTime(TimerTask task) { in checkScheduledExecutionTime()
79 final TimerTask task = new TimerTask() { in test() local
|
| D | Purge.java | 41 TimerTask task = new TimerTask() { in main() local
|
| D | NameConstructors.java | 49 TimerTask task = new TimerTask() { in test() local
|
| /libcore/luni/src/test/java/libcore/java/util/concurrent/ |
| D | ForkJoinTaskTest.java | 42 final ForkJoinTask task = ForkJoinTask.adapt(() -> result.addAndGet(42), result); in testAdaptToRunnableWithResult() local
61 final ForkJoinTask task = ForkJoinTask.adapt(callable); in testAdaptToCallable() local
80 final ForkJoinTask task = ForkJoinTask.adapt(callable); in testAdaptToCallableThrowsException() local
|
| D | ForkJoinPoolTest.java | 41 ForkJoinTask task = pool.submit(() -> result.addAndGet(42), result); in testSubmit() local
58 ForkJoinTask task = pool.submit(new Runnable() { in testGetRunningThreadCount() local
|
| D | FutureTaskTest.java | 39 FutureTask task = new FutureTask(callable); in testRecursiveToString() local
|
| D | RecursiveTaskTest.java | 63 SumTask task = new SumTask(10); in testSetRawResult() local
|
| /libcore/ojluni/annotations/hiddenapi/java/util/concurrent/ |
| D | Executors.java | 120 public static <T> java.util.concurrent.Callable<T> callable(java.lang.Runnable task, T result) { in callable()
125 java.lang.Runnable task) { in callable()
218 public java.util.concurrent.Future<?> submit(java.lang.Runnable task) { in submit()
222 public <T> java.util.concurrent.Future<T> submit(java.util.concurrent.Callable<T> task) { in submit()
226 public <T> java.util.concurrent.Future<T> submit(java.lang.Runnable task, T result) { in submit()
328 PrivilegedCallable(java.util.concurrent.Callable<T> task) { in PrivilegedCallable()
342 final java.util.concurrent.Callable<T> task; field in Executors.PrivilegedCallable
353 PrivilegedCallableUsingCurrentClassLoader(java.util.concurrent.Callable<T> task) { in PrivilegedCallableUsingCurrentClassLoader()
373 final java.util.concurrent.Callable<T> task; field in Executors.PrivilegedCallableUsingCurrentClassLoader
408 RunnableAdapter(java.lang.Runnable task, T result) { in RunnableAdapter()
[all …]
|
| /libcore/luni/src/test/java/tests/support/ |
| D | ThreadPool.java | 44 public synchronized void runTask(Runnable task) { in runTask()
99 Runnable task = null; in run() local
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| D | Cancellable.java | 38 void onCancel(PendingFuture<?,?> task); in onCancel()
|
| D | SimpleAsynchronousFileChannelImpl.java | 196 Runnable task = new Runnable() { in implLock() local
311 Runnable task = new Runnable() { in implRead() local
365 Runnable task = new Runnable() { in implWrite() local
|
| D | AsynchronousChannelGroupImpl.java | 107 private Runnable bindToGroup(final Runnable task) { in bindToGroup()
|
| /libcore/ojluni/src/main/java/sun/nio/fs/ |
| D | Cancellable.java | 119 static void runInterruptibly(Cancellable task) throws ExecutionException { in runInterruptibly()
|