| /aosp_15_r20/external/zxing/javase/src/main/java/com/google/zxing/client/j2se/ |
| H A D | CommandLineRunner.java | 89 ExecutorService executor = Executors.newFixedThreadPool(numThreads); in main() local
90 Collection<Future<Integer>> futures = new ArrayList<>(numThreads); in main() local
|
| /aosp_15_r20/cts/tests/sensor/src/android/hardware/cts/helpers/sensoroperations/ |
| H A D | ParallelSensorOperation.java | 86 ThreadPoolExecutor executor = new ThreadPoolExecutor( in execute() local
96 ArrayList<Future<SensorOperation>> futures = new ArrayList<>(); in execute() local
|
| /aosp_15_r20/external/jackson-core/src/test/java/com/fasterxml/jackson/core/json/async/ |
| H A D | AsyncConcurrencyTest.java | 111 final ExecutorService executor = Executors.newFixedThreadPool(numThreads); in _testConcurrentAsyncOnce() local
125 ArrayList<Future<?>> futures = new ArrayList<Future<?>>(); in _testConcurrentAsyncOnce() local
|
| /aosp_15_r20/external/dagger2/javatests/dagger/internal/ |
| H A D | DoubleCheckTest.java | 77 ExecutorService executor = Executors.newFixedThreadPool(numThreads); in get() local
92 List<Future<Object>> futures = executor.invokeAll(tasks); in get() local
|
| /aosp_15_r20/external/aws-sdk-java-v2/utils/src/test/java/software/amazon/awssdk/utils/async/ |
| H A D | InputStreamSubscriberTest.java | 179 …ExecutorService executor = Executors.newFixedThreadPool(10, new ThreadFactoryBuilder().daemonThrea… in stochastic_methodCallsSeemThreadSafe() local
181 List<Future<?>> futures = new ArrayList<>(); in stochastic_methodCallsSeemThreadSafe() local
|
| /aosp_15_r20/external/guava/android/guava-tests/test/com/google/common/graph/ |
| H A D | ValueGraphTest.java | 416 ExecutorService executor = newFixedThreadPool(threadCount); in concurrentIteration() local
418 ImmutableList.Builder<Future<?>> futures = ImmutableList.builder(); in concurrentIteration() local
|
| H A D | AbstractNetworkTest.java | 814 ExecutorService executor = newFixedThreadPool(threadCount); in concurrentIteration() local
816 ImmutableList.Builder<Future<?>> futures = ImmutableList.builder(); in concurrentIteration() local
|
| /aosp_15_r20/external/guava/guava-tests/test/com/google/common/graph/ |
| H A D | ValueGraphTest.java | 482 ExecutorService executor = newFixedThreadPool(threadCount); in concurrentIteration() local
484 ImmutableList.Builder<Future<?>> futures = ImmutableList.builder(); in concurrentIteration() local
|
| H A D | AbstractNetworkTest.java | 821 ExecutorService executor = newFixedThreadPool(threadCount); in concurrentIteration() local
823 ImmutableList.Builder<Future<?>> futures = ImmutableList.builder(); in concurrentIteration() local
|
| /aosp_15_r20/tools/tradefederation/core/src/com/android/tradefed/util/ |
| D | RemoteZip.java | 228 ParallelDeviceExecutor<Long> executor = in downloadFiles() local
233 List<Future<IOException>> futures = Collections.synchronizedList(new ArrayList<>()); in downloadFiles() local
|
| /aosp_15_r20/system/update_engine/aosp/ |
| H A D | ota_extractor.cc | 104 InstallOperationExecutor executor(manifest.block_size()); in ExtractImageFromPartition() local
226 std::vector<std::pair<std::future<bool>, std::string>> futures; in ExtractImagesFromOTA() local
|
| /aosp_15_r20/external/guava/guava-tests/test/com/google/common/eventbus/ |
| H A D | EventBusTest.java | 236 List<Future<?>> futures = Lists.newArrayList(); in testRegisterThreadSafety() local
237 ExecutorService executor = Executors.newFixedThreadPool(10); in testRegisterThreadSafety() local
|
| /aosp_15_r20/external/guava/android/guava-tests/test/com/google/common/eventbus/ |
| H A D | EventBusTest.java | 236 List<Future<?>> futures = Lists.newArrayList(); in testRegisterThreadSafety() local
237 ExecutorService executor = Executors.newFixedThreadPool(10); in testRegisterThreadSafety() local
|
| /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
229 ExecutorService executor = Executors.newSingleThreadExecutor(); in explicitExecutor_shouldUseExecutor() local
|
| /aosp_15_r20/external/cronet/components/cronet/android/test/javaperftests/src/org/chromium/net/ |
| H A D | CronetPerfTestActivity.java | 517 final ExecutorService executor = Executors.newFixedThreadPool(mConcurrency); in run() local
542 List<Future<Boolean>> futures = new ArrayList<>(); in run() local
|
| /aosp_15_r20/external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/extensions/media2/src/androidTest/java/com/google/android/exoplayer2/ext/media2/ |
| H A D | SessionPlayerConnectorTest.java | 80 private Executor executor; field in SessionPlayerConnectorTest
427 List<ListenableFuture<PlayerResult>> futures = new ArrayList<>(); in seekTo_whenUnderlyingPlayerAlsoSeeks_throwsNoException() local
|
| /aosp_15_r20/external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/extensions/media2/src/androidTest/java/com/google/android/exoplayer2/ext/media2/ |
| H A D | SessionPlayerConnectorTest.java | 80 private Executor executor; field in SessionPlayerConnectorTest
427 List<ListenableFuture<PlayerResult>> futures = new ArrayList<>(); in seekTo_whenUnderlyingPlayerAlsoSeeks_throwsNoException() local
|
| /aosp_15_r20/external/rust/android-crates-io/crates/futures/ |
| D | Cargo.toml | 15 name = "futures" package
352 executor = [ qkey
|
| /aosp_15_r20/libcore/ojluni/src/test/java/util/concurrent/tck/ |
| H A D | CompletableFutureTest.java | 3695 List<CompletableFuture<?>> futures = new ArrayList<>(); in testRejectingExecutor() local
4037 ThreadExecutor executor = new ThreadExecutor(); in testCompleteAsync3() local
4038 f.completeAsync(() -> v1, executor); in testCompleteAsync3() local
4052 ThreadExecutor executor = new ThreadExecutor(); in testCompleteAsync4() local
4147 private void testDelayedExecutor(Executor executor, Item v) throws Exception { in testDelayedExecutor()
4850 Executor executor) { in thenRunAsync()
4860 Executor executor) { in thenAcceptAsync()
4870 Executor executor) { in thenApplyAsync()
4883 Executor executor) { in thenCombineAsync()
4896 Executor executor) { in thenAcceptBothAsync()
[all …]
|
| /aosp_15_r20/out/soong/.intermediates/prebuilts/sdk/current/androidx/m2repository/androidx/work/work-runtime/2.10.0-rc01/androidx.work_work-runtime/android_common/aar/ |
| D | classes.jar | ... $Builder setExecutor (java.util.concurrent.Executor)
java.util.concurrent.Executor executor
public ... |
| /aosp_15_r20/out/soong/.intermediates/prebuilts/sdk/current/androidx/m2repository/androidx/work/work-runtime/2.10.0-rc01/androidx.work_work-runtime/android_common_apex33/aar/ |
| D | classes.jar | ... $Builder setExecutor (java.util.concurrent.Executor)
java.util.concurrent.Executor executor
public ... |
| D | androidx.work_work-runtime.jar | ... $Builder setExecutor (java.util.concurrent.Executor)
java.util.concurrent.Executor executor
public ... |
| /aosp_15_r20/out/soong/.intermediates/prebuilts/sdk/current/androidx/m2repository/androidx/work/work-runtime/2.10.0-rc01/androidx.work_work-runtime/android_common_apex34/aar/ |
| D | androidx.work_work-runtime.jar | ... $Builder setExecutor (java.util.concurrent.Executor)
java.util.concurrent.Executor executor
public ... |
| D | classes.jar | ... $Builder setExecutor (java.util.concurrent.Executor)
java.util.concurrent.Executor executor
public ... |
| /aosp_15_r20/out/soong/.intermediates/prebuilts/sdk/current/androidx/m2repository/androidx/work/work-runtime/2.10.0-rc01/androidx.work_work-runtime/android_common_apex30/aar/ |
| D | classes.jar | ... $Builder setExecutor (java.util.concurrent.Executor)
java.util.concurrent.Executor executor
public ... |