| /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 …]
|
| D | ScheduledExecutorTest.java | 56 final Runnable task = new CheckedRunnable() { in testExecute() local
71 Callable task = new CheckedCallable<Boolean>() { in testSchedule1() local
92 Runnable task = new CheckedRunnable() { in testSchedule3() local
112 Runnable task = new CheckedRunnable() { in testSchedule4() local
134 Runnable task = new CheckedRunnable() { in testSchedule5() local
165 final Runnable task = new CheckedRunnable() { in testFixedRateSequence() local
197 final Runnable task = new CheckedRunnable() { in testFixedDelaySequence() local
769 Runnable task = new CheckedRunnable() { public void realRun() in testShutdown_cancellation() local
|
| /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 | 75 private final RunnableScheduledFuture<V> task; field in ScheduledExecutorSubclassTest.CustomTask
77 CustomTask(RunnableScheduledFuture<V> task) { this.task = task; } in CustomTask()
106 …rotected <V> RunnableScheduledFuture<V> decorateTask(Runnable r, RunnableScheduledFuture<V> task) { in decorateTask()
110 …ected <V> RunnableScheduledFuture<V> decorateTask(Callable<V> c, RunnableScheduledFuture<V> task) { in decorateTask()
135 final Runnable task = new CheckedRunnable() { in testExecute() local
150 Callable task = new CheckedCallable<Boolean>() { in testSchedule1() local
170 Runnable task = new CheckedRunnable() { in testSchedule3() local
190 Runnable task = new CheckedRunnable() { in testSchedule4() local
212 Runnable task = new CheckedRunnable() { in testSchedule5() local
243 final Runnable task = new CheckedRunnable() { in testFixedRateSequence() local
[all …]
|
| D | ScheduledExecutorTest.java | 78 final Runnable task = new CheckedRunnable() { in testExecute() local
93 Callable task = new CheckedCallable<Boolean>() { in testSchedule1() local
114 Runnable task = new CheckedRunnable() { in testSchedule3() local
134 Runnable task = new CheckedRunnable() { in testSchedule4() local
156 Runnable task = new CheckedRunnable() { in testSchedule5() local
187 final Runnable task = new CheckedRunnable() { in testFixedRateSequence() local
219 final Runnable task = new CheckedRunnable() { in testFixedDelaySequence() local
790 Runnable task = new CheckedRunnable() { public void realRun() in testShutdown_cancellation() local
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | ExecutorCompletionService.java | 115 QueueingFuture(RunnableFuture<V> task, in QueueingFuture()
121 private final Future<V> task; field in ExecutorCompletionService.QueueingFuture
126 private RunnableFuture<V> newTaskFor(Callable<V> task) { in newTaskFor()
133 private RunnableFuture<V> newTaskFor(Runnable task, V result) { in newTaskFor()
180 public Future<V> submit(Callable<V> task) { in submit()
187 public Future<V> submit(Runnable task, V result) { in submit()
|
| D | CompletionService.java | 73 Future<V> submit(Callable<V> task); in submit()
89 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 | 115 public Future<?> submit(Runnable task) { in submit()
126 public <T> Future<T> submit(Runnable task, T result) { in submit()
137 public <T> Future<T> submit(Callable<T> task) { in submit()
|
| D | Executors.java | 381 public static <T> Callable<T> callable(Runnable task, T result) { in callable()
394 public static Callable<Object> callable(Runnable task) { in callable()
|
| D | ForkJoinPool.java | 870 final void push(ForkJoinTask<?> task) { in push()
1004 final boolean tryUnpush(ForkJoinTask<?> task) { in tryUnpush()
1022 final int sharedPush(ForkJoinTask<?> task) { in sharedPush()
1047 private void growAndSharedPush(ForkJoinTask<?> task) { in growAndSharedPush()
1063 final boolean trySharedUnpush(ForkJoinTask<?> task) { in trySharedUnpush()
1153 final void runTask(ForkJoinTask<?> task) { in runTask()
1194 final boolean tryRemoveAndExec(ForkJoinTask<?> task) { in tryRemoveAndExec()
1247 final CountedCompleter<?> popCC(CountedCompleter<?> task, int mode) { in popCC()
1297 final int pollAndExecCC(CountedCompleter<?> task) { in pollAndExecCC()
2035 final int helpComplete(WorkQueue w, CountedCompleter<?> task, in helpComplete()
[all …]
|
| D | ScheduledThreadPoolExecutor.java | 332 private void delayedExecute(RunnableScheduledFuture<?> task) { in delayedExecute()
352 void reExecutePeriodic(RunnableScheduledFuture<?> task) { in reExecutePeriodic()
408 Runnable runnable, RunnableScheduledFuture<V> task) { in decorateTask()
425 Callable<V> callable, RunnableScheduledFuture<V> task) { in decorateTask()
663 public Future<?> submit(Runnable task) { in submit()
671 public <T> Future<T> submit(Runnable task, T result) { in submit()
679 public <T> Future<T> submit(Callable<T> task) { in submit()
|
| /libcore/ojluni/src/main/java/java/util/ |
| D | Timer.java | 197 public void schedule(TimerTask task, long delay) { in schedule()
214 public void schedule(TimerTask task, Date time) { in schedule()
250 public void schedule(TimerTask task, long delay, long period) { in schedule()
291 public void schedule(TimerTask task, Date firstTime, long period) { in schedule()
330 public void scheduleAtFixedRate(TimerTask task, long delay, long period) { in scheduleAtFixedRate()
373 public void scheduleAtFixedRate(TimerTask task, Date firstTime, in scheduleAtFixedRate()
393 private void sched(TimerTask task, long time, long period) { in sched()
528 TimerTask task; in mainLoop() 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 | 40 ForkJoinTask task = pool.submit(() -> result.addAndGet(42), result); in testSubmit() local
56 ForkJoinTask task = pool.submit(new Runnable() { in testGetRunningThreadCount() 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()
|
| D | EPollPort.java | 144 void executeOnHandlerTask(Runnable task) { in executeOnHandlerTask()
280 Runnable task = pollTask(); in run() local
|
| /libcore/ojluni/src/main/java/sun/nio/fs/ |
| D | Cancellable.java | 119 static void runInterruptibly(Cancellable task) throws ExecutionException { in runInterruptibly()
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/ |
| D | TimerTest.java | 102 private void awaitRun(TimerTestTask task) throws Exception { in awaitRun()
1032 TimerTask task = new TimerTask() { in testCanBeCancelledEvenIfTaskKeepsItPermanentlyBusy() local
1070 TimerTask task = new TimerTask() { in testTaskNotCancelledWhenTimerCancelled() local
1092 TimerTask task = new TimerTask() { in testTaskNotCancelledWhenTimerCancelledAndPurged() local
|