Home
last modified time | relevance | path

Searched defs:task (Results 1 – 25 of 33) 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
DExecutorsTest.java206 final Runnable task = new CheckedRunnable() { in testNewSingleThreadScheduledExecutor() local
230 final Runnable task = new CheckedRunnable() { in testNewScheduledThreadPool() local
256 final Runnable task = new CheckedRunnable() { in testUnconfigurableScheduledExecutorService() local
DThreadPoolExecutorTest.java97 final Runnable task = new CheckedRunnable() { in testExecute() local
554 Callable task = new CheckedCallable<Boolean>() { in testGetQueue() local
620 Callable task = new CheckedCallable<Boolean>() { in testPurge() local
1064 Runnable task = new CheckedRunnable() { in testSaturatedExecute() local
1090 Runnable task = new CheckedRunnable() { in testSaturatedSubmitRunnable() local
1116 Runnable task = new CheckedRunnable() { in testSaturatedSubmitCallable() local
/libcore/ojluni/src/main/java/java/util/concurrent/
DExecutorCompletionService.java115 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()
DCompletionService.java73 Future<V> submit(Callable<V> task); in submit()
89 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.java378 public static <T> Callable<T> callable(Runnable task, T result) { in callable()
391 public static Callable<Object> callable(Runnable task) { in callable()
DForkJoinPool.java867 final void push(ForkJoinTask<?> task) { in push()
1001 final boolean tryUnpush(ForkJoinTask<?> task) { in tryUnpush()
1019 final int sharedPush(ForkJoinTask<?> task) { in sharedPush()
1044 private void growAndSharedPush(ForkJoinTask<?> task) { in growAndSharedPush()
1060 final boolean trySharedUnpush(ForkJoinTask<?> task) { in trySharedUnpush()
1150 final void runTask(ForkJoinTask<?> task) { in runTask()
1191 final boolean tryRemoveAndExec(ForkJoinTask<?> task) { in tryRemoveAndExec()
1244 final CountedCompleter<?> popCC(CountedCompleter<?> task, int mode) { in popCC()
1294 final int pollAndExecCC(CountedCompleter<?> task) { in pollAndExecCC()
2032 final int helpComplete(WorkQueue w, CountedCompleter<?> task, in helpComplete()
[all …]
DScheduledThreadPoolExecutor.java332 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/
DTimer.java190 public void schedule(TimerTask task, long delay) { in schedule()
207 public void schedule(TimerTask task, Date time) { in schedule()
243 public void schedule(TimerTask task, long delay, long period) { in schedule()
284 public void schedule(TimerTask task, Date firstTime, long period) { in schedule()
323 public void scheduleAtFixedRate(TimerTask task, long delay, long period) { in scheduleAtFixedRate()
366 public void scheduleAtFixedRate(TimerTask task, Date firstTime, in scheduleAtFixedRate()
386 private void sched(TimerTask task, long time, long period) { in sched()
521 TimerTask task; in mainLoop() local
/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
DAsynchronousServerSocketChannelImpl.java142 public final void onCancel(PendingFuture<?,?> task) { in onCancel()
DPendingFuture.java107 void setTimeoutTask(Future<?> task) { in setTimeoutTask()
/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
/libcore/ojluni/src/main/java/java/util/stream/
DAbstractShortCircuitTask.java106 @SuppressWarnings("unchecked") K task = (K) this; in compute() local
DAbstractTask.java296 @SuppressWarnings("unchecked") K task = (K) this; in compute() local
DForEachOps.java287 ForEachTask<S, T> task = this; in compute() local
403 private static <S, T> void doCompute(ForEachOrderedTask<S, T> task) { in doCompute()

12