/external/robolectric/v1/src/test/java/com/xtremelabs/robolectric/util/ |
H A D | RobolectricBackgroundExecutorServiceTest.java | 19 private RobolectricBackgroundExecutorService executorService; field in class:RobolectricBackgroundExecutorServiceTest 24 executorService = new RobolectricBackgroundExecutorService(); 37 executorService.execute(runnable); 47 Future<String> future = executorService.submit(runnable, "foo"); 61 Future<String> future = executorService.submit(new Callable<String>() {
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
H A D | Dispatcher.java | 41 private ExecutorService executorService; field in class:Dispatcher 52 public Dispatcher(ExecutorService executorService) { argument 53 this.executorService = executorService; 60 if (executorService == null) { 61 executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS, 64 return executorService;
|
/external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/badexecutor/ |
H A D | BadExecutorTest.java | 31 ListeningExecutorService executorService = MoreExecutors.newDirectExecutorService(); 34 .executor(executorService) 37 executorService.shutdown();
|
/external/mockito/src/test/java/org/mockitousage/serialization/ |
H A D | ParallelSerializationTest.java | 28 final ExecutorService executorService = Executors.newFixedThreadPool(threadingFactor); 41 futures.add(executorService.submit(new Callable<Object>() { 52 executorService.submit(new Callable<Object>() {
|
/external/r8/src/main/java/com/android/tools/r8/dex/ |
H A D | ApplicationReader.java | 72 public final DexApplication read(ExecutorService executorService) argument 85 readProguardMap(builder, executorService, futures, closer); 86 readMainDexList(builder, executorService, futures, closer); 87 ClassReader classReader = new ClassReader(executorService, futures, closer); 130 private void readProguardMap(DexApplication.Builder builder, ExecutorService executorService, argument 135 futures.add(executorService.submit(() -> { 146 private void readMainDexList(DexApplication.Builder builder, ExecutorService executorService, argument 150 futures.add(executorService.submit(() -> { 162 private final ExecutorService executorService; field in class:ApplicationReader.ClassReader 174 ClassReader(ExecutorService executorService, Lis argument [all...] |
H A D | ApplicationWriter.java | 121 public AndroidApp write(PackageDistribution packageDistribution, ExecutorService executorService) argument 148 distributor = new PackageMapDistributor(this, packageDistribution, executorService); 161 dexDataFutures.put(newFile, executorService.submit(() -> writeDexFile(newFile)));
|
H A D | VirtualFile.java | 351 private final ExecutorService executorService; field in class:VirtualFile.PackageMapDistributor 356 ExecutorService executorService) { 359 this.executorService = executorService; 416 futures.add(executorService.submit(populator)); 353 PackageMapDistributor( ApplicationWriter writer, PackageDistribution packageDistribution, ExecutorService executorService) argument
|
/external/r8/src/test/java/com/android/tools/r8/ |
H A D | R8UnreachableCodeTest.java | 34 ExecutorService executorService = Executors.newSingleThreadExecutor(); 37 new ApplicationReader(input, new InternalOptions(), timing).read(executorService);
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
H A D | JdkFutureAdaptersTest.java | 83 ExecutorService executorService = newCachedThreadPool( 87 ExecutorSpy spy = new ExecutorSpy(executorService); 98 listenableFuture.addListener(singleCallListener, executorService); 111 ExecutorService executorService = new ThreadPoolExecutor( 123 listenInPoolThread(abstractFuture, executorService); 138 executorService.shutdownNow();
|
/external/r8/src/main/java/com/android/tools/r8/ |
H A D | R8.java | 75 ExecutorService executorService, 85 .write(packageDistribution, executorService); 98 GraphLense graphLense, ExecutorService executorService) 106 application = converter.optimize(executorService); 192 private CompilationResult run(AndroidApp inputApp, ExecutorService executorService) argument 204 new ApplicationReader(inputApp, options, timing).read(executorService); 224 rootSet = new RootSetBuilder(application, appInfo, options.keepRules).run(executorService); 275 application = optimize(application, appInfo, graphLense, executorService); 282 new RootSetBuilder(application, appInfo, options.mainDexKeepRules).run(executorService); 342 executorService, 74 writeApplication( ExecutorService executorService, DexApplication application, AppInfo appInfo, NamingLens namingLens, byte[] proguardSeedsData, PackageDistribution packageDistribution, InternalOptions options) argument 97 optimize(DexApplication application, AppInfoWithSubtyping appInfo, GraphLense graphLense, ExecutorService executorService) argument [all...] |
H A D | PrintClassList.java | 41 ExecutorService executorService = Executors.newCachedThreadPool(); 44 .read(executorService); 54 executorService.shutdown();
|
/external/guava/guava/src/com/google/common/util/concurrent/ |
H A D | AbstractScheduledService.java | 164 private volatile ScheduledExecutorService executorService; 191 executorService = MoreExecutors.renamingDecorator(executor(), new Supplier<String>() { 196 executorService.execute(new Runnable() { 201 runningTask = scheduler().schedule(delegate, executorService, task); 215 executorService.execute(new Runnable() {
|
H A D | MoreExecutors.java | 672 */ static <T> T invokeAnyImpl(ListeningExecutorService executorService, argument 675 checkNotNull(executorService); 694 futures.add(submitAndAddQueueListener(executorService, it.next(), futureQueue)); 703 futures.add(submitAndAddQueueListener(executorService, it.next(), futureQueue)); 746 ListeningExecutorService executorService, Callable<T> task, 748 final ListenableFuture<T> future = executorService.submit(task); 745 submitAndAddQueueListener( ListeningExecutorService executorService, Callable<T> task, final BlockingQueue<Future<T>> queue) argument
|
/external/r8/src/test/java/com/android/tools/r8/internal/ |
H A D | R8GMSCoreLookupTest.java | 38 ExecutorService executorService = Executors.newSingleThreadExecutor(); 40 program = new ApplicationReader(app, new InternalOptions(), timing).read(executorService);
|
/external/guava/guava-testlib/test/com/google/common/testing/ |
H A D | FakeTickerTest.java | 150 ExecutorService executorService = Executors.newFixedThreadPool(numberOfThreads); 154 executorService.submit(new Callable<Void>() {
|
/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
H A D | ExecutionListBenchmark.java | 153 private ExecutorService executorService; field in class:ExecutionListBenchmark 167 executorService = new ThreadPoolExecutor(NUM_THREADS, 175 executorService.submit(new Runnable() { 183 executorService.shutdown(); 244 executorService.submit(addTask); 246 executorService.submit(executeTask); 265 executorService.submit(executeTask); 267 executorService.submit(addTask);
|
/external/guice/extensions/servlet/test/com/google/inject/servlet/ |
H A D | ContinuingRequestIntegrationTest.java | 201 @Inject ExecutorService executorService; field in class:ContinuingRequestIntegrationTest.ContinuingServlet 214 executorService.submit(task);
|
/external/glide/third_party/disklrucache/src/main/java/com/bumptech/glide/disklrucache/ |
H A D | DiskLruCache.java | 158 final ThreadPoolExecutor executorService = field in class:DiskLruCache 430 executorService.submit(cleanupCallable); 489 executorService.submit(cleanupCallable); 560 executorService.submit(cleanupCallable); 605 executorService.submit(cleanupCallable);
|
/external/guice/core/test/com/google/inject/ |
H A D | InjectorTest.java | 390 final ExecutorService executorService = Executors.newSingleThreadExecutor(); 398 Future<JustInTime> future = executorService.submit(new Callable<JustInTime>() {
|
/external/mockito/src/test/java/org/mockitoutil/ |
H A D | ClassLoaders.java | 103 ExecutorService executorService = Executors.newSingleThreadExecutor(new ThreadFactory() { 112 Future<?> taskFuture = executorService.submit(new Runnable() { 126 executorService.shutdownNow();
|
/external/r8/src/main/java/com/android/tools/r8/ir/conversion/ |
H A D | IRConverter.java | 264 public DexApplication optimize(ExecutorService executorService) throws ExecutionException { argument 289 futures.add(executorService.submit(() -> {
|
/external/r8/src/main/java/com/android/tools/r8/shaking/ |
H A D | RootSetBuilder.java | 204 public RootSet run(ExecutorService executorService) throws ExecutionException { argument 223 futures.add(executorService.submit(() -> {
|
/external/caliper/lib/ |
H A D | jersey-client-1.11.jar | META-INF/MANIFEST.MF META-INF/ META-INF/maven/ META-INF/maven/com. ... |
/external/guice/extensions/persist/lib/ |
H A D | hibernate-search.jar | META-INF/ META-INF/MANIFEST.MF org/ org/hibernate/ org/hibernate/search/ org/hibernate/search/annotations/ ... |
/external/r8/deps/ |
H A D | commons-compress-1.12.jar | META-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/commons/ org/apache/commons/compress/ ... |