| /aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/19/libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | AbstractExecutorService.java | 120 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()
160 ArrayList<Future<T>> futures = new ArrayList<>(ntasks); in doInvokeAny() local
242 ArrayList<Future<T>> futures = new ArrayList<>(tasks.size()); in invokeAll() local
270 ArrayList<Future<T>> futures = new ArrayList<>(tasks.size()); in invokeAll() local
306 private static <T> void cancelAll(ArrayList<Future<T>> futures) { in cancelAll()
311 private static <T> void cancelAll(ArrayList<Future<T>> futures, int j) { in cancelAll()
|
| /aosp_15_r20/libcore/ojluni/src/main/java/java/util/concurrent/ |
| H A D | AbstractExecutorService.java | 120 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()
160 ArrayList<Future<T>> futures = new ArrayList<>(ntasks); in doInvokeAny() local
242 ArrayList<Future<T>> futures = new ArrayList<>(tasks.size()); in invokeAll() local
270 ArrayList<Future<T>> futures = new ArrayList<>(tasks.size()); in invokeAll() local
306 private static <T> void cancelAll(ArrayList<Future<T>> futures) { in cancelAll()
311 private static <T> void cancelAll(ArrayList<Future<T>> futures, int j) { in cancelAll()
|
| /aosp_15_r20/out/soong/.intermediates/libcore/core_oj_api_files/gen/gensrcs/libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | AbstractExecutorService.java | 120 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()
160 ArrayList<Future<T>> futures = new ArrayList<>(ntasks); in doInvokeAny() local
242 ArrayList<Future<T>> futures = new ArrayList<>(tasks.size()); in invokeAll() local
270 ArrayList<Future<T>> futures = new ArrayList<>(tasks.size()); in invokeAll() local
306 private static <T> void cancelAll(ArrayList<Future<T>> futures) { in cancelAll()
311 private static <T> void cancelAll(ArrayList<Future<T>> futures, int j) { in cancelAll()
|
| /aosp_15_r20/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| H A D | WrappingExecutorServiceTest.java | 87 Callable<String> task = Callables.returning(RESULT_VALUE); in testSubmit() local
99 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll() local
108 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll() local
134 private static void checkResults(List<Future<String>> futures) in checkResults()
272 public <T> Future<T> submit(Callable<T> task) { in submit()
279 public Future<?> submit(Runnable task) { in submit()
286 public <T> Future<T> submit(Runnable task, T result) { in submit()
|
| /aosp_15_r20/external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| H A D | WrappingExecutorServiceTest.java | 87 Callable<String> task = Callables.returning(RESULT_VALUE); in testSubmit() local
99 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll() local
108 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll() local
134 private static void checkResults(List<Future<String>> futures) in checkResults()
272 public <T> Future<T> submit(Callable<T> task) { in submit()
279 public Future<?> submit(Runnable task) { in submit()
286 public <T> Future<T> submit(Runnable task, T result) { in submit()
|
| /aosp_15_r20/out/soong/.intermediates/prebuilts/sdk/current/androidx/m2repository/androidx/concurrent/concurrent-futures/1.3.0-alpha01/androidx.concurrent_concurrent-futures/android_common_apex34/local-combined/ |
| D | androidx.concurrent_concurrent-futures.jar | ... concurrent.futures.AbstractResolvableFuture$Listener TOMBSTONE
final Runnable task
final java.util.concurrent.Executor executor
androidx ... |
| /aosp_15_r20/out/soong/.intermediates/prebuilts/sdk/current/androidx/m2repository/androidx/concurrent/concurrent-futures/1.3.0-alpha01/androidx.concurrent_concurrent-futures/android_common_apex30/local-combined/ |
| D | androidx.concurrent_concurrent-futures.jar | ... concurrent.futures.AbstractResolvableFuture$Listener TOMBSTONE
final Runnable task
final java.util.concurrent.Executor executor
androidx ... |
| /aosp_15_r20/out/soong/.intermediates/prebuilts/sdk/current/androidx/m2repository/androidx/concurrent/concurrent-futures/1.3.0-alpha01/androidx.concurrent_concurrent-futures/android_common_apex35/local-combined/ |
| D | androidx.concurrent_concurrent-futures.jar | ... concurrent.futures.AbstractResolvableFuture$Listener TOMBSTONE
final Runnable task
final java.util.concurrent.Executor executor
androidx ... |
| /aosp_15_r20/out/soong/.intermediates/prebuilts/sdk/current/androidx/m2repository/androidx/concurrent/concurrent-futures/1.3.0-alpha01/androidx.concurrent_concurrent-futures/android_common_apex10000/local-combined/ |
| D | androidx.concurrent_concurrent-futures.jar | ... concurrent.futures.AbstractResolvableFuture$Listener TOMBSTONE
final Runnable task
final java.util.concurrent.Executor executor
androidx ... |
| /aosp_15_r20/prebuilts/sdk/current/androidx/m2repository/androidx/concurrent/concurrent-futures/1.3.0-alpha01/ |
| HD | concurrent-futures-1.3.0-alpha01.jar | ... concurrent.futures.AbstractResolvableFuture$Listener TOMBSTONE
final Runnable task
final java.util.concurrent.Executor executor
androidx ... |
| /aosp_15_r20/out/soong/.intermediates/prebuilts/sdk/current/androidx/m2repository/androidx/concurrent/concurrent-futures/1.3.0-alpha01/androidx.concurrent_concurrent-futures/android_common/local-combined/ |
| D | androidx.concurrent_concurrent-futures.jar | ... concurrent.futures.AbstractResolvableFuture$Listener TOMBSTONE
final Runnable task
final java.util.concurrent.Executor executor
androidx ... |
| /aosp_15_r20/out/soong/.intermediates/prebuilts/sdk/current/androidx/m2repository/androidx/concurrent/concurrent-futures/1.3.0-alpha01/androidx.concurrent_concurrent-futures/android_common_apex33/local-combined/ |
| D | androidx.concurrent_concurrent-futures.jar | ... concurrent.futures.AbstractResolvableFuture$Listener TOMBSTONE
final Runnable task
final java.util.concurrent.Executor executor
androidx ... |
| /aosp_15_r20/external/sdv/vsomeip/third_party/boost/thread/test/ |
| D | test_futures.cpp | 1110 boost::unique_future<int> futures[count]; in BOOST_AUTO_TEST_CASE() local
1142 boost::unique_future<int> futures[count]; in BOOST_AUTO_TEST_CASE() local
1145 boost::packaged_task<int> task(make_int_slowly); in BOOST_AUTO_TEST_CASE() local
1162 boost::unique_future<int> futures[count]; in BOOST_AUTO_TEST_CASE() local
1165 boost::packaged_task<int> task(make_int_slowly); in BOOST_AUTO_TEST_CASE() local
1182 boost::unique_future<int> futures[count]; in BOOST_AUTO_TEST_CASE() local
1185 boost::packaged_task<int> task(make_int_slowly); in BOOST_AUTO_TEST_CASE() local
1202 boost::unique_future<int> futures[count]; in BOOST_AUTO_TEST_CASE() local
1205 boost::packaged_task<int> task(make_int_slowly); in BOOST_AUTO_TEST_CASE() local
1222 boost::unique_future<int> futures[count]; in BOOST_AUTO_TEST_CASE() local
[all …]
|
| /aosp_15_r20/external/guava/guava/src/com/google/common/util/concurrent/ |
| H A D | ClosingFuture.java | 392 TrustedListenableFutureTask<V> task = in submit() local
421 TrustedListenableFutureTask<V> task = in submitAsync() local
504 public static Combiner whenAllComplete(Iterable<? extends ClosingFuture<?>> futures) { in whenAllComplete()
526 public static Combiner whenAllSucceed(Iterable<? extends ClosingFuture<?>> futures) { in whenAllSucceed()
|
| H A D | CombinedFuture.java | 37 @CheckForNull @LazyInit private CombinedFutureInterruptibleTask<?> task; field in CombinedFuture
40 ImmutableCollection<? extends ListenableFuture<?>> futures, in CombinedFuture()
50 ImmutableCollection<? extends ListenableFuture<?>> futures, in CombinedFuture()
|
| /aosp_15_r20/external/guava/android/guava/src/com/google/common/util/concurrent/ |
| H A D | ClosingFuture.java | 387 TrustedListenableFutureTask<V> task = in submit() local
416 TrustedListenableFutureTask<V> task = in submitAsync() local
499 public static Combiner whenAllComplete(Iterable<? extends ClosingFuture<?>> futures) { in whenAllComplete()
521 public static Combiner whenAllSucceed(Iterable<? extends ClosingFuture<?>> futures) { in whenAllSucceed()
|
| H A D | CombinedFuture.java | 37 @CheckForNull @LazyInit private CombinedFutureInterruptibleTask<?> task; field in CombinedFuture
40 ImmutableCollection<? extends ListenableFuture<?>> futures, in CombinedFuture()
50 ImmutableCollection<? extends ListenableFuture<?>> futures, in CombinedFuture()
|
| H A D | MoreExecutors.java | 494 TrustedListenableFutureTask<@Nullable Void> task = in schedule() local
503 TrustedListenableFutureTask<V> task = TrustedListenableFutureTask.create(callable); in schedule() local
511 NeverSuccessfulListenableFutureTask task = new NeverSuccessfulListenableFutureTask(command); in scheduleAtFixedRate() local
519 NeverSuccessfulListenableFutureTask task = new NeverSuccessfulListenableFutureTask(command); in scheduleWithFixedDelay() local
620 List<Future<T>> futures = Lists.newArrayListWithCapacity(ntasks); in invokeAnyImpl() local
694 Callable<T> task, in submitAndAddQueueListener()
|
| /aosp_15_r20/libcore/ojluni/src/test/java/util/concurrent/tck/ |
| H A D | ScheduledExecutorSubclassTest.java | 90 private final RunnableScheduledFuture<V> task; field in ScheduledExecutorSubclassTest.CustomTask
92 CustomTask(RunnableScheduledFuture<V> task) { this.task = task; } in CustomTask()
121 …rotected <V> RunnableScheduledFuture<V> decorateTask(Runnable r, RunnableScheduledFuture<V> task) { in decorateTask()
125 …ected <V> RunnableScheduledFuture<V> decorateTask(Callable<V> c, RunnableScheduledFuture<V> task) { in decorateTask()
151 final Runnable task = new CheckedRunnable() { in testExecute() local
167 Callable task = new CheckedCallable<Boolean>() { in testSchedule1() local
188 Runnable task = new CheckedRunnable() { in testSchedule3() local
209 Runnable task = new CheckedRunnable() { in testSchedule4() local
232 Runnable task = new CheckedRunnable() { in testSchedule5() local
264 final Runnable task = new CheckedRunnable() { in testFixedRateSequence() local
[all …]
|
| H A D | FutureTaskTest.java | 297 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testIsDone() local
310 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testRunAndReset() local
327 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testRunAndResetAfterCancel() local
346 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testSet() local
364 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testSetException_get() local
395 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testCancelBeforeRun() local
413 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testCancelBeforeRun2() local
431 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testCancelAfterRun() local
447 PublicFutureTask task = new PublicFutureTask(new NoOpCallable()); in testCancelAfterRun2() local
464 final PublicFutureTask task = in testCancelInterrupt() local
[all …]
|
| H A D | ScheduledExecutorTest.java | 108 final Runnable task = new CheckedRunnable() { in testExecute() local
124 Callable task = new CheckedCallable<Boolean>() { in testSchedule1() local
146 Runnable task = new CheckedRunnable() { in testSchedule3() local
167 Runnable task = new CheckedRunnable() { in testSchedule4() local
190 Runnable task = new CheckedRunnable() { in testSchedule5() local
222 final Runnable task = new CheckedRunnable() { in testFixedRateSequence() local
266 final Runnable task = new CheckedRunnable() { in testFixedRateSequenceSkipMultipleMissedFixedRateTasksEnabled() local
319 final Runnable task = new CheckedRunnable() { in testFixedRateSequenceSkipMultipleMissedFixedRateTasksDisabled() local
363 final Runnable task = new CheckedRunnable() { in testFixedDelaySequence() local
960 Runnable task = new CheckedRunnable() { public void realRun() in testShutdown_cancellation() local
[all …]
|
| /aosp_15_r20/libcore/jsr166-tests/src/test/java/jsr166/ |
| H A 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 …]
|
| H A 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
988 List<Future<String>> futures = e.invokeAll(l); in testInvokeAll4() local
1008 List<Future<String>> futures = e.invokeAll(l); in testInvokeAll5() local
|
| H A 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 …]
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/async/ |
| H A D | FileAsyncResponseTransformerTest.java | 98 List<CompletableFuture> futures = new ArrayList<>(); in synchronousPublisher_shouldNotHang() local
315 public <T> Future<T> submit(Callable<T> task) { in submit()
321 public <T> Future<T> submit(Runnable task, T result) { in submit()
327 public Future<?> submit(Runnable task) { in submit()
|