Home
last modified time | relevance | path

Searched refs:callable (Results 1 – 25 of 36) sorted by relevance

12

/libcore/luni/src/test/java/libcore/java/util/concurrent/
DFutureTaskTest.java44 TestCallable callable = new TestCallable(); in testRecursiveToString() local
45 FutureTask task = new FutureTask(callable); in testRecursiveToString()
46 callable.set(task); in testRecursiveToString()
48 assertFalse(callable.hasDetectedRecursiveToString()); in testRecursiveToString()
53 TestCallable callable = new TestCallable(); in testExceptionNow_OnSuccess() local
54 FutureTask task = new FutureTask(callable); in testExceptionNow_OnSuccess()
63 TestCallable callable = new TestCallable(); in testExceptionNow_OnCancel() local
64 FutureTask task = new FutureTask(callable); in testExceptionNow_OnCancel()
73 TestCallable callable = new TestCallable(); in testExceptionNow_OnFail() local
74 FutureTask task = new FutureTask(callable); in testExceptionNow_OnFail()
[all …]
DForkJoinTaskTest.java60 Callable callable = () -> { return Integer.valueOf(42); }; in testAdaptToCallable() local
61 final ForkJoinTask task = ForkJoinTask.adapt(callable); in testAdaptToCallable()
79 Callable callable = () -> { throw new Exception("Test passed"); }; in testAdaptToCallableThrowsException() local
80 final ForkJoinTask task = ForkJoinTask.adapt(callable); in testAdaptToCallableThrowsException()
/libcore/ojluni/src/main/java/java/util/concurrent/
DFutureTask.java102 private Callable<V> callable; field in FutureTask
132 public FutureTask(Callable<V> callable) { in FutureTask() argument
133 if (callable == null) in FutureTask()
135 this.callable = callable; in FutureTask()
152 this.callable = Executors.callable(runnable, result); in FutureTask()
312 Callable<V> c = callable; in run()
355 Callable<V> c = callable; in runAndReset()
436 callable = null; // to reduce footprint in finishCompletion()
DExecutors.java427 public static <T> Callable<T> callable(Runnable task, T result) { in callable() method in Executors
440 public static Callable<Object> callable(Runnable task) { in callable() method in Executors
453 public static Callable<Object> callable(final PrivilegedAction<?> action) { in callable() method in Executors
468 public static Callable<Object> callable(final PrivilegedExceptionAction<?> action) {
487 public static <T> Callable<T> privilegedCallable(Callable<T> callable) {
488 if (callable == null)
490 return new PrivilegedCallable<T>(callable);
505 public static <T> Callable<T> privilegedCallableUsingCurrentClassLoader(Callable<T> callable) {
506 if (callable == null)
508 return new PrivilegedCallableUsingCurrentClassLoader<T>(callable);
[all …]
DForkJoinTask.java1450 final Callable<? extends T> callable; field in ForkJoinTask.AdaptedCallable
1453 AdaptedCallable(Callable<? extends T> callable) { in AdaptedCallable() argument
1454 if (callable == null) throw new NullPointerException(); in AdaptedCallable()
1455 this.callable = callable; in AdaptedCallable()
1461 result = callable.call(); in exec()
1471 return super.toString() + "[Wrapped task = " + callable + "]"; in toString()
1479 final Callable<? extends T> callable; field in ForkJoinTask.AdaptedInterruptibleCallable
1483 AdaptedInterruptibleCallable(Callable<? extends T> callable) { in AdaptedInterruptibleCallable() argument
1484 if (callable == null) throw new NullPointerException(); in AdaptedInterruptibleCallable()
1485 this.callable = callable; in AdaptedInterruptibleCallable()
[all …]
DScheduledThreadPoolExecutor.java267 ScheduledFutureTask(Callable<V> callable, long triggerTime, in ScheduledFutureTask() argument
269 super(callable); in ScheduledFutureTask()
473 Callable<V> callable, RunnableScheduledFuture<V> task) { in decorateTask() argument
618 public <V> ScheduledFuture<V> schedule(Callable<V> callable, in schedule() argument
621 if (callable == null || unit == null) in schedule()
623 RunnableScheduledFuture<V> t = decorateTask(callable, in schedule()
624 new ScheduledFutureTask<V>(callable, in schedule()
778 return schedule(Executors.callable(task, result), 0, NANOSECONDS); in submit()
DScheduledExecutorService.java122 public <V> ScheduledFuture<V> schedule(Callable<V> callable, in schedule() argument
DAbstractExecutorService.java112 protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable) { in newTaskFor() argument
113 return new FutureTask<T>(callable); in newTaskFor()
DForkJoinPool.java3104 final Callable<E> callable;
3106 InvokeAnyTask(InvokeAnyRoot<E> root, Callable<E> callable) {
3108 this.callable = callable;
3113 root.tryComplete(callable);
3818 protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable) {
3819 return new ForkJoinTask.AdaptedCallable<T>(callable);
/libcore/jsr166-tests/src/test/java/jsr166/
DExecutorsTest.java211 Future f = p.schedule(Executors.callable(task, Boolean.TRUE), in testNewSingleThreadScheduledExecutor()
235 Future f = p.schedule(Executors.callable(task, Boolean.TRUE), in testNewScheduledThreadPool()
261 Future f = p.schedule(Executors.callable(task, Boolean.TRUE), in testUnconfigurableScheduledExecutorService()
532 Callable c = Executors.callable(new NoOpRunnable()); in testCallable1()
540 Callable c = Executors.callable(new NoOpRunnable(), one); in testCallable2()
548 Callable c = Executors.callable(new PrivilegedAction() { in testCallable3()
557 Callable c = Executors.callable(new PrivilegedExceptionAction() { in testCallable4()
567 Callable c = Executors.callable((Runnable) null); in testCallableNPE1()
577 Callable c = Executors.callable((Runnable) null, one); in testCallableNPE2()
587 Callable c = Executors.callable((PrivilegedAction) null); in testCallableNPE3()
[all …]
DForkJoinPoolTest.java485 final Callable callable = Executors.callable(new PrivilegedAction() { in testSubmitPrivilegedAction() local
491 Future future = e.submit(callable); in testSubmitPrivilegedAction()
503 final Callable callable = in testSubmitPrivilegedExceptionAction() local
504 Executors.callable(new PrivilegedExceptionAction() { in testSubmitPrivilegedExceptionAction()
510 Future future = e.submit(callable); in testSubmitPrivilegedExceptionAction()
522 final Callable callable = in testSubmitFailedPrivilegedExceptionAction() local
523 Executors.callable(new PrivilegedExceptionAction() { in testSubmitFailedPrivilegedExceptionAction()
529 Future future = e.submit(callable); in testSubmitFailedPrivilegedExceptionAction()
DFutureTaskTest.java196 PublicFutureTask(Callable callable) { in PublicFutureTask() argument
197 this(callable, new AtomicInteger(0)); in PublicFutureTask()
199 private PublicFutureTask(final Callable callable, in PublicFutureTask() argument
204 return callable.call(); in PublicFutureTask()
633 final Callable<Object> callable = in testTimedGet_Cancellation() local
646 final PublicFutureTask task = new PublicFutureTask(callable); in testTimedGet_Cancellation()
DAbstractExecutorServiceTest.java118 Future future = e.submit(Executors.callable(new PrivilegedAction() { in testSubmitPrivilegedAction()
139 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() { in testSubmitPrivilegedExceptionAction()
157 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() { in testSubmitFailedPrivilegedExceptionAction()
587 tasks.add(Executors.callable(possiblyInterruptedRunnable(timeout),
/libcore/ojluni/src/test/java/util/concurrent/tck/
DExecutorsTest.java263 Future f = p.schedule(Executors.callable(task, Boolean.TRUE), in testNewSingleThreadScheduledExecutor()
288 Future f = p.schedule(Executors.callable(task, Boolean.TRUE), in testNewScheduledThreadPool()
315 Future f = p.schedule(Executors.callable(task, Boolean.TRUE), in testUnconfigurableScheduledExecutorService()
599 Callable c = Executors.callable(new NoOpRunnable()); in testCallable1()
608 Callable c = Executors.callable(new NoOpRunnable(), one); in testCallable2()
617 Callable c = Executors.callable(new PrivilegedAction() { in testCallable3()
627 Callable c = Executors.callable(new PrivilegedExceptionAction() { in testCallable4()
638 Callable c = Executors.callable((Runnable) null); in testCallableNPE1()
649 Callable c = Executors.callable((Runnable) null, one); in testCallableNPE2()
660 Callable c = Executors.callable((PrivilegedAction) null); in testCallableNPE3()
[all …]
DForkJoinPoolTest.java534 final Callable callable = Executors.callable(new PrivilegedAction() { in testSubmitPrivilegedAction() local
540 Future future = e.submit(callable); in testSubmitPrivilegedAction()
554 final Callable callable = in testSubmitPrivilegedExceptionAction() local
555 Executors.callable(new PrivilegedExceptionAction() { in testSubmitPrivilegedExceptionAction()
561 Future future = e.submit(callable); in testSubmitPrivilegedExceptionAction()
575 final Callable callable = in testSubmitFailedPrivilegedExceptionAction() local
576 Executors.callable(new PrivilegedExceptionAction() { in testSubmitFailedPrivilegedExceptionAction()
582 Future future = e.submit(callable); in testSubmitFailedPrivilegedExceptionAction()
DFutureTaskTest.java231 PublicFutureTask(Callable callable) { in PublicFutureTask() argument
232 this(callable, new AtomicInteger(0)); in PublicFutureTask()
234 private PublicFutureTask(final Callable callable, in PublicFutureTask() argument
239 return callable.call(); in PublicFutureTask()
687 final Callable<Object> callable = in testTimedGet_Cancellation() local
700 final PublicFutureTask task = new PublicFutureTask(callable); in testTimedGet_Cancellation()
DAbstractExecutorServiceTest.java161 Future future = e.submit(Executors.callable(new PrivilegedAction() { in testSubmitPrivilegedAction()
184 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() { in testSubmitPrivilegedExceptionAction()
204 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() { in testSubmitFailedPrivilegedExceptionAction()
661 tasks.add(Executors.callable(possiblyInterruptedRunnable(timeout),
/libcore/luni/src/test/java/libcore/java/lang/
DLambdaImplementationTest.java152 Callable<String> callable = (Callable<String> & Serializable) () -> "No State"; in testSerializableLambda_withoutState() local
153 assertLambdaImplementsInterfaces(callable, Callable.class, Serializable.class); in testSerializableLambda_withoutState()
154 callables.add(callable); in testSerializableLambda_withoutState()
175 Callable<String> callable = (Callable<String> & Serializable) () -> "State:" + state; in testSerializableLambda_withState() local
176 assertLambdaImplementsInterfaces(callable, Callable.class, Serializable.class); in testSerializableLambda_withState()
177 callables.add(callable); in testSerializableLambda_withState()
209 Callable<String> callable = in testMultipleInterfaceLambda() local
211 assertLambdaImplementsInterfaces(callable, Callable.class, MarkerInterface.class); in testMultipleInterfaceLambda()
212 callables.add(callable); in testMultipleInterfaceLambda()
/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() method in Executors
124 public static java.util.concurrent.Callable<java.lang.Object> callable( in callable() method in Executors
129 public static java.util.concurrent.Callable<java.lang.Object> callable( in callable() method in Executors
134 public static java.util.concurrent.Callable<java.lang.Object> callable( in callable() method in Executors
140 java.util.concurrent.Callable<T> callable) { in privilegedCallable() argument
145 java.util.concurrent.Callable<T> callable) { in privilegedCallableUsingCurrentClassLoader() argument
282 java.util.concurrent.Callable<V> callable, in schedule() argument
DFutureTask.java43 public FutureTask(java.util.concurrent.Callable<V> callable) { in FutureTask() argument
153 private java.util.concurrent.Callable<V> callable; field in FutureTask
/libcore/ojluni/src/test/java/lang/invoke/
DInvokeGenericTest.java305 MethodHandle callable(List<Class<?>> params) { in callable() method in InvokeGenericTest
313 MethodHandle callable(Class<?>... params) { in callable() method in InvokeGenericTest
314 return callable(Arrays.asList(params)); in callable()
336 MethodHandle mh = callable(Object.class, String.class); in testSimple()
348 MethodHandle mh = callable(Object.class, Object.class); in testSimplePrims()
360 MethodHandle mh = callable(Object.class, String.class); in testAlternateName()
394 MethodHandle target = callable(expect); in testWrongArgumentCount()
472 MethodHandle mh = callable(type.parameterList()); in testReferenceConversions()
507 MethodHandle mh = callable(Object.class, int.class); in testBoxConversions()
/libcore/ojluni/annotations/flagged_api/java/util/concurrent/
DForkJoinTask.annotated.java48 …urrent.ForkJoinTask<T> adapt(java.util.concurrent.Callable<? extends T> callable) { throw new Runt… in adapt() argument
51 …inTask<T> adaptInterruptible(java.util.concurrent.Callable<? extends T> callable) { throw new Runt… in adaptInterruptible() argument
DFutureTask.annotated.java44 public FutureTask(java.util.concurrent.Callable<V> callable) { throw new RuntimeException("Stub!");… in FutureTask() argument
/libcore/luni/src/test/java/libcore/sun/misc/
DUnsafeTest.java44 Callable<Object> callable = Executors.callable(new Runnable() { in test_getUnsafeForbiddenWithSystemCaller() local
51 callable.call(); in test_getUnsafeForbiddenWithSystemCaller()
/libcore/luni/src/test/java/libcore/libcore/net/
DNetworkSecurityPolicyTest.java258 Callable<byte[]> callable = () -> { in CapturingServerSocket() local
280 mFirstChunkReceivedFuture = executor.submit(callable); in CapturingServerSocket()

12