Searched refs:executorService (Results 1 - 25 of 39) sorted by relevance

12

/external/robolectric/v1/src/test/java/com/xtremelabs/robolectric/util/
H A DRobolectricBackgroundExecutorServiceTest.java19 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 DDispatcher.java41 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 DBadExecutorTest.java31 ListeningExecutorService executorService = MoreExecutors.newDirectExecutorService();
34 .executor(executorService)
37 executorService.shutdown();
/external/mockito/src/test/java/org/mockitousage/serialization/
H A DParallelSerializationTest.java28 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 DApplicationReader.java72 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 DApplicationWriter.java121 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 DVirtualFile.java351 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 DR8UnreachableCodeTest.java34 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 DJdkFutureAdaptersTest.java83 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 DR8.java75 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 DPrintClassList.java41 ExecutorService executorService = Executors.newCachedThreadPool();
44 .read(executorService);
54 executorService.shutdown();
/external/guava/guava/src/com/google/common/util/concurrent/
H A DAbstractScheduledService.java164 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 DMoreExecutors.java672 */ 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 DR8GMSCoreLookupTest.java38 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 DFakeTickerTest.java150 ExecutorService executorService = Executors.newFixedThreadPool(numberOfThreads);
154 executorService.submit(new Callable<Void>() {
/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/
H A DExecutionListBenchmark.java153 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 DContinuingRequestIntegrationTest.java201 @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 DDiskLruCache.java158 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 DInjectorTest.java390 final ExecutorService executorService = Executors.newSingleThreadExecutor();
398 Future<JustInTime> future = executorService.submit(new Callable<JustInTime>() {
/external/mockito/src/test/java/org/mockitoutil/
H A DClassLoaders.java103 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 DIRConverter.java264 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 DRootSetBuilder.java204 public RootSet run(ExecutorService executorService) throws ExecutionException { argument
223 futures.add(executorService.submit(() -> {
/external/caliper/lib/
H A Djersey-client-1.11.jarMETA-INF/MANIFEST.MF META-INF/ META-INF/maven/ META-INF/maven/com. ...
/external/guice/extensions/persist/lib/
H A Dhibernate-search.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/hibernate/ org/hibernate/search/ org/hibernate/search/annotations/ ...
/external/r8/deps/
H A Dcommons-compress-1.12.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/commons/ org/apache/commons/compress/ ...

Completed in 965 milliseconds

12