Home
last modified time | relevance | path

Searched defs:task (Results 1 – 25 of 50) 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 …]
/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.java77 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/
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.java120 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()
DExecutors.java390 public static <T> Callable<T> callable(Runnable task, T result) { in callable()
403 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.java209 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/
DArgs.java39 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()
DDelayOverflow.java43 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
DPurge.java41 TimerTask task = new TimerTask() { in main() local
DNameConstructors.java49 TimerTask task = new TimerTask() { in test() 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.java41 ForkJoinTask task = pool.submit(() -> result.addAndGet(42), result); in testSubmit() local
58 ForkJoinTask task = pool.submit(new Runnable() { in testGetRunningThreadCount() local
DFutureTaskTest.java39 FutureTask task = new FutureTask(callable); in testRecursiveToString() 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()
/libcore/ojluni/src/main/java/sun/nio/fs/
DCancellable.java119 static void runInterruptibly(Cancellable task) throws ExecutionException { in runInterruptibly()

12