| /aosp_15_r20/external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/tracing/ |
| H A D | PropagatedFutures.java | 40 Executor executor) { in transformAsync()
46 ListenableFuture<I> input, Function<? super I, ? extends O> function, Executor executor) { in transform()
51 ListenableFuture<V> future, FutureCallback<? super V> callback, Executor executor) { in addCallback()
59 Executor executor) { in catching()
67 Executor executor) { in catchingAsync()
72 Callable<V> callable, Executor executor) { in submit()
76 public static ListenableFuture<@Nullable Void> submit(Runnable runnable, Executor executor) { in submit()
81 AsyncCallable<V> callable, Executor executor) { in submitAsync()
86 AsyncCallable<V> callable, long delay, TimeUnit timeUnit, ScheduledExecutorService executor) { in scheduleAsync()
91 public static <V extends @Nullable Object> PropagatedFutureCombiner<V> whenAllComplete( in whenAllComplete()
[all …]
|
| /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 | ... final Runnable task
final java.util.concurrent.Executor executor
androidx.concurrent.futures.AbstractResolvableFuture$Listener ... |
| /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 | ... final Runnable task
final java.util.concurrent.Executor executor
androidx.concurrent.futures.AbstractResolvableFuture$Listener ... |
| /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 | ... final Runnable task
final java.util.concurrent.Executor executor
androidx.concurrent.futures.AbstractResolvableFuture$Listener ... |
| /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 | ... final Runnable task
final java.util.concurrent.Executor executor
androidx.concurrent.futures.AbstractResolvableFuture$Listener ... |
| /aosp_15_r20/prebuilts/sdk/current/androidx/m2repository/androidx/concurrent/concurrent-futures/1.3.0-alpha01/ |
| HD | concurrent-futures-1.3.0-alpha01.jar | ... final Runnable task
final java.util.concurrent.Executor executor
androidx.concurrent.futures.AbstractResolvableFuture$Listener ... |
| /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 | ... final Runnable task
final java.util.concurrent.Executor executor
androidx.concurrent.futures.AbstractResolvableFuture$Listener ... |
| /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 | ... final Runnable task
final java.util.concurrent.Executor executor
androidx.concurrent.futures.AbstractResolvableFuture$Listener ... |
| /aosp_15_r20/external/jimfs/jimfs/src/test/java/com/google/common/jimfs/ |
| H A D | JimfsFileChannelTest.java | 308 ExecutorService executor = Executors.newSingleThreadExecutor(); in testClose() local
678 ExecutorService executor = Executors.newCachedThreadPool(); in testAsynchronousClose() local
681 List<Future<?>> futures = queueAllBlockingOperations(channel, executor, latch); in testAsynchronousClose() local
712 ExecutorService executor = Executors.newCachedThreadPool(); in testCloseByInterrupt() local
744 List<Future<?>> futures = queueAllBlockingOperations(channel, executor, blockingStartLatch); in testCloseByInterrupt() local
783 final FileChannel channel, ExecutorService executor, final CountDownLatch startLatch) { in queueAllBlockingOperations()
784 List<Future<?>> futures = new ArrayList<>(); in queueAllBlockingOperations() local
|
| /aosp_15_r20/external/guava/guava/src/com/google/common/util/concurrent/ |
| H A D | ClosingFuture.java | 389 ClosingCallable<V> callable, Executor executor) { in submit()
418 AsyncClosingCallable<V> callable, Executor executor) { in submitAsync()
504 public static Combiner whenAllComplete(Iterable<? extends ClosingFuture<?>> futures) { in whenAllComplete()
526 public static Combiner whenAllSucceed(Iterable<? extends ClosingFuture<?>> futures) { in whenAllSucceed()
692 final ClosingFunction<? super V, U> function, Executor executor) { in transform()
786 final AsyncClosingFunction<? super V, U> function, Executor executor) { in transformAsync()
|
| H A D | MoreExecutors.java | 85 ThreadPoolExecutor executor, Duration terminationTimeout) { in getExitingExecutorService()
107 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
126 public static ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
146 ScheduledThreadPoolExecutor executor, Duration terminationTimeout) { in getExitingScheduledExecutorService()
168 ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingScheduledExecutorService()
189 ScheduledThreadPoolExecutor executor) { in getExitingScheduledExecutorService()
236 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
243 final ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
248 ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingScheduledExecutorService()
256 ScheduledThreadPoolExecutor executor) { in getExitingScheduledExecutorService()
[all …]
|
| /aosp_15_r20/external/guava/android/guava/src/com/google/common/util/concurrent/ |
| H A D | ClosingFuture.java | 384 ClosingCallable<V> callable, Executor executor) { in submit()
413 AsyncClosingCallable<V> callable, Executor executor) { in submitAsync()
499 public static Combiner whenAllComplete(Iterable<? extends ClosingFuture<?>> futures) { in whenAllComplete()
521 public static Combiner whenAllSucceed(Iterable<? extends ClosingFuture<?>> futures) { in whenAllSucceed()
687 final ClosingFunction<? super V, U> function, Executor executor) { in transform()
781 final AsyncClosingFunction<? super V, U> function, Executor executor) { in transformAsync()
|
| H A D | MoreExecutors.java | 84 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
103 public static ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
124 ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingScheduledExecutorService()
145 ScheduledThreadPoolExecutor executor) { in getExitingScheduledExecutorService()
175 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingExecutorService()
182 final ExecutorService getExitingExecutorService(ThreadPoolExecutor executor) { in getExitingExecutorService()
187 ScheduledThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) { in getExitingScheduledExecutorService()
195 ScheduledThreadPoolExecutor executor) { in getExitingScheduledExecutorService()
232 private static void useDaemonThreadFactory(ThreadPoolExecutor executor) { in useDaemonThreadFactory()
620 List<Future<T>> futures = Lists.newArrayListWithCapacity(ntasks); in invokeAnyImpl() local
[all …]
|
| /aosp_15_r20/out/soong/.intermediates/prebuilts/sdk/current/androidx/m2repository/androidx/concurrent/concurrent-futures-ktx/1.3.0-alpha01/androidx.concurrent_concurrent-futures-ktx/android_common_apex34/local-combined/ |
| D | androidx.concurrent_concurrent-futures-ktx.jar | ... androidx/concurrent/futures/
androidx/concurrent/futures/ListenableFutureKt$await$2$1.class ... |
| /aosp_15_r20/out/soong/.intermediates/prebuilts/sdk/current/androidx/m2repository/androidx/concurrent/concurrent-futures-ktx/1.3.0-alpha01/androidx.concurrent_concurrent-futures-ktx/android_common/local-combined/ |
| D | androidx.concurrent_concurrent-futures-ktx.jar | ... androidx/concurrent/futures/
androidx/concurrent/futures/ListenableFutureKt$await$2$1.class ... |
| /aosp_15_r20/out/soong/.intermediates/prebuilts/sdk/current/androidx/m2repository/androidx/concurrent/concurrent-futures-ktx/1.3.0-alpha01/androidx.concurrent_concurrent-futures-ktx/android_common_apex33/local-combined/ |
| D | androidx.concurrent_concurrent-futures-ktx.jar | ... androidx/concurrent/futures/
androidx/concurrent/futures/ListenableFutureKt$await$2$1.class ... |
| /aosp_15_r20/prebuilts/sdk/current/androidx/m2repository/androidx/concurrent/concurrent-futures-ktx/1.3.0-alpha01/ |
| HD | concurrent-futures-ktx-1.3.0-alpha01.jar | ... androidx/concurrent/futures/
androidx/concurrent/futures/ListenableFutureKt$await$2$1.class ... |
| /aosp_15_r20/out/soong/.intermediates/prebuilts/sdk/current/androidx/m2repository/androidx/concurrent/concurrent-futures-ktx/1.3.0-alpha01/androidx.concurrent_concurrent-futures-ktx/android_common_apex30/local-combined/ |
| D | androidx.concurrent_concurrent-futures-ktx.jar | ... androidx/concurrent/futures/
androidx/concurrent/futures/ListenableFutureKt$await$2$1.class ... |
| /aosp_15_r20/external/sdk-platform-java/api-common-java/src/main/java/com/google/api/core/ |
| H A D | ApiFutures.java | 78 final ApiFuture<V> future, final ApiFutureCallback<? super V> callback, Executor executor) { in addCallback()
138 Executor executor) { in catching()
169 Executor executor) { in catchingAsync()
260 Executor executor) { in transform()
281 Iterable<? extends ApiFuture<? extends V>> futures) { in allAsList()
|
| /aosp_15_r20/external/aws-sdk-java-v2/utils/src/test/java/software/amazon/awssdk/utils/cache/ |
| H A D | CachedSupplierTest.java | 212 List<Future<?>> futures = performAsyncGets(cachedSupplier, 2); in staleValueBlocksAllCalls() local
246 List<Future<?>> futures = performAsyncGets(cachedSupplier, 2); in staleValueBlocksAllCallsEvenWithStaleValuesAllowed() local
513 ExecutorService executor = Executors.newCachedThreadPool(); in activeThreadsHaveMaxCount() local
590 List<Future<?>> futures = new ArrayList<>(); in performAsyncGets() local
608 private void waitFor(Collection<Future<?>> futures) { in waitFor()
|
| /aosp_15_r20/external/aws-sdk-java-v2/utils/src/main/java/software/amazon/awssdk/utils/ |
| H A D | CompletableFutureUtils.java | 138 Executor executor) { in forwardResultTo()
181 public static CompletableFuture<Void> allOfExceptionForwarded(CompletableFuture<?>[] futures) { in allOfExceptionForwarded()
204 static CompletableFuture<Void> anyFail(CompletableFuture<?>[] futures) { in anyFail()
|
| /aosp_15_r20/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| H A D | MoreExecutorsTest.java | 94 final ListeningExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceInThreadExecution() local
142 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceInvokeAll() local
161 List<Future<Integer>> futures = executor.invokeAll(Collections.nCopies(10, incrementTask)); in testDirectExecutorServiceInvokeAll() local
173 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceTermination() local
295 ExecutorService executor = newDirectExecutorService(); in testDirectExecutorService_shutdownNow() local
301 ExecutorService executor = newDirectExecutorService(); in testExecuteAfterShutdown() local
307 ListeningExecutorService executor = newDirectExecutorService(); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles() local
575 ThreadPoolExecutor executor = in testGetExitingExecutorService_executorSetToUseDaemonThreads() local
584 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_executorDelegatesToOriginal() local
594 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_shutdownHookRegistered() local
[all …]
|
| /aosp_15_r20/external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| H A D | MoreExecutorsTest.java | 94 final ListeningExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceInThreadExecution() local
142 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceInvokeAll() local
161 List<Future<Integer>> futures = executor.invokeAll(Collections.nCopies(10, incrementTask)); in testDirectExecutorServiceInvokeAll() local
173 final ExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceTermination() local
295 ExecutorService executor = newDirectExecutorService(); in testDirectExecutorService_shutdownNow() local
301 ExecutorService executor = newDirectExecutorService(); in testExecuteAfterShutdown() local
307 ListeningExecutorService executor = newDirectExecutorService(); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles() local
575 ThreadPoolExecutor executor = in testGetExitingExecutorService_executorSetToUseDaemonThreads() local
584 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_executorDelegatesToOriginal() local
594 ThreadPoolExecutor executor = mock(ThreadPoolExecutor.class); in testGetExitingExecutorService_shutdownHookRegistered() local
[all …]
|
| /aosp_15_r20/external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
| H A D | ExperimentingCaliperRun.java | 154 final ListeningExecutorService executor = executorProvider.get(); in run() local
205 final ListeningExecutorService executor) { in scheduleTrials()
283 Iterable<? extends ListenableFuture<? extends T>> futures) { in inCompletionOrder()
|
| /aosp_15_r20/tools/tradefederation/core/src/com/android/tradefed/util/executor/ |
| D | ParallelDeviceExecutor.java | 73 ExecutorService executor = in invokeAll() local
77 List<Future<V>> futures = in invokeAll() local
|