Home
last modified time | relevance | path

Searched defs:task (Results 1 – 25 of 45) sorted by relevance

12

/libcore/jsr166-tests/src/test/java/jsr166/
DFutureTaskTest.java259 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 …]
DScheduledExecutorSubclassTest.java53 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 …]
DScheduledExecutorTest.java56 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/
DFutureTaskTest.java282 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 …]
DScheduledExecutorSubclassTest.java75 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 …]
DScheduledExecutorTest.java78 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
DExecutorsTest.java229 final Runnable task = new CheckedRunnable() { in testNewSingleThreadScheduledExecutor() local
253 final Runnable task = new CheckedRunnable() { in testNewScheduledThreadPool() local
279 final Runnable task = new CheckedRunnable() { in testUnconfigurableScheduledExecutorService() local
/libcore/ojluni/src/main/java/java/util/concurrent/
DExecutorCompletionService.java112 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()
DCompletionService.java75 Future<V> submit(Callable<V> task); in submit()
91 Future<V> submit(Runnable task, V result); in submit()
DExecutorService.java226 <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()
DAbstractExecutorService.java115 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()
DExecutors.java382 public static <T> Callable<T> callable(Runnable task, T result) { in callable()
395 public static Callable<Object> callable(Runnable task) { in callable()
DScheduledThreadPoolExecutor.java319 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/
DTimer.java198 public void schedule(TimerTask task, long delay) { in schedule()
215 public void schedule(TimerTask task, Date time) { in schedule()
251 public void schedule(TimerTask task, long delay, long period) { in schedule()
292 public void schedule(TimerTask task, Date firstTime, long period) { in schedule()
331 public void scheduleAtFixedRate(TimerTask task, long delay, long period) { in scheduleAtFixedRate()
374 public void scheduleAtFixedRate(TimerTask task, Date firstTime, in scheduleAtFixedRate()
394 private void sched(TimerTask task, long time, long period) { in sched()
529 TimerTask task; in mainLoop() local
/libcore/luni/src/test/java/libcore/java/util/concurrent/
DForkJoinTaskTest.java42 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
DForkJoinPoolTest.java40 ForkJoinTask task = pool.submit(() -> result.addAndGet(42), result); in testSubmit() local
56 ForkJoinTask task = pool.submit(new Runnable() { in testGetRunningThreadCount() local
DRecursiveTaskTest.java63 SumTask task = new SumTask(10); in testSetRawResult() local
/libcore/ojluni/annotations/hiddenapi/java/util/concurrent/
DExecutors.java120 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/
DThreadPool.java44 public synchronized void runTask(Runnable task) { in runTask()
99 Runnable task = null; in run() local
/libcore/ojluni/src/main/java/sun/nio/ch/
DCancellable.java38 void onCancel(PendingFuture<?,?> task); in onCancel()
DSimpleAsynchronousFileChannelImpl.java196 Runnable task = new Runnable() { in implLock() local
311 Runnable task = new Runnable() { in implRead() local
365 Runnable task = new Runnable() { in implWrite() local
DAsynchronousChannelGroupImpl.java107 private Runnable bindToGroup(final Runnable task) { in bindToGroup()
DEPollPort.java144 void executeOnHandlerTask(Runnable task) { in executeOnHandlerTask()
280 Runnable task = pollTask(); in run() local
/libcore/ojluni/src/main/java/sun/nio/fs/
DCancellable.java119 static void runInterruptibly(Cancellable task) throws ExecutionException { in runInterruptibly()
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/
DTimerTest.java102 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

12