| /external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
| D | Dispatcher.java | 41 private ExecutorService executorService; field in Dispatcher
52 public Dispatcher(ExecutorService executorService) { in Dispatcher() argument
53 this.executorService = executorService; in Dispatcher()
60 if (executorService == null) { in getExecutorService()
61 executorService = new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60, TimeUnit.SECONDS, in getExecutorService()
64 return executorService; in getExecutorService()
|
| /external/r8/src/main/java/com/android/tools/r8/dex/ |
| D | ApplicationReader.java | 72 public final DexApplication read(ExecutorService executorService) in read() argument
85 readProguardMap(builder, executorService, futures, closer); in read()
86 readMainDexList(builder, executorService, futures, closer); in read()
87 ClassReader classReader = new ClassReader(executorService, futures, closer); in read()
130 private void readProguardMap(DexApplication.Builder builder, ExecutorService executorService, in readProguardMap() argument
135 futures.add(executorService.submit(() -> { in readProguardMap()
146 private void readMainDexList(DexApplication.Builder builder, ExecutorService executorService, in readMainDexList() argument
150 futures.add(executorService.submit(() -> { in readMainDexList()
162 private final ExecutorService executorService; field in ApplicationReader.ClassReader
174 ClassReader(ExecutorService executorService, List<Future<?>> futures, Closer closer) { in ClassReader() argument
[all …]
|
| D | ApplicationWriter.java | 121 public AndroidApp write(PackageDistribution packageDistribution, ExecutorService executorService) in write() argument
148 distributor = new PackageMapDistributor(this, packageDistribution, executorService); in write()
161 dexDataFutures.put(newFile, executorService.submit(() -> writeDexFile(newFile))); in write()
|
| D | VirtualFile.java | 351 private final ExecutorService executorService; field in VirtualFile.PackageMapDistributor
356 ExecutorService executorService) { in PackageMapDistributor() argument
359 this.executorService = executorService; in PackageMapDistributor()
416 futures.add(executorService.submit(populator)); in fillForDistribution()
|
| /external/robolectric/v1/src/test/java/com/xtremelabs/robolectric/util/ |
| D | RobolectricBackgroundExecutorServiceTest.java | 19 private RobolectricBackgroundExecutorService executorService; field in RobolectricBackgroundExecutorServiceTest
24 executorService = new RobolectricBackgroundExecutorService(); in setUp()
37 executorService.execute(runnable); in execute_shouldRunStuffOnBackgroundThread()
47 Future<String> future = executorService.submit(runnable, "foo"); in submitRunnable_shouldRunStuffOnBackgroundThread()
61 Future<String> future = executorService.submit(new Callable<String>() { in submitCallable_shouldRunStuffOnBackgroundThread()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | JdkFutureAdaptersTest.java | 83 ExecutorService executorService = newCachedThreadPool( in testListenInPoolThreadUsesGivenExecutor() local
87 ExecutorSpy spy = new ExecutorSpy(executorService); in testListenInPoolThreadUsesGivenExecutor()
98 listenableFuture.addListener(singleCallListener, executorService); in testListenInPoolThreadUsesGivenExecutor()
111 ExecutorService executorService = new ThreadPoolExecutor( in testListenInPoolThreadCustomExecutorInterrupted() local
123 listenInPoolThread(abstractFuture, executorService); in testListenInPoolThreadCustomExecutorInterrupted()
138 executorService.shutdownNow(); in testListenInPoolThreadCustomExecutorInterrupted()
|
| /external/r8/src/main/java/com/android/tools/r8/ |
| D | R8.java | 75 ExecutorService executorService, in writeApplication() argument
85 .write(packageDistribution, executorService); in writeApplication()
98 GraphLense graphLense, ExecutorService executorService) in optimize() argument
106 application = converter.optimize(executorService); in optimize()
192 private CompilationResult run(AndroidApp inputApp, ExecutorService executorService) in run() argument
204 new ApplicationReader(inputApp, options, timing).read(executorService); in run()
224 rootSet = new RootSetBuilder(application, appInfo, options.keepRules).run(executorService); in run()
275 application = optimize(application, appInfo, graphLense, executorService); in run()
282 new RootSetBuilder(application, appInfo, options.mainDexKeepRules).run(executorService); in run()
342 executorService, in run()
[all …]
|
| D | PrintClassList.java | 41 ExecutorService executorService = Executors.newCachedThreadPool(); in main() local
44 .read(executorService); in main()
54 executorService.shutdown(); in main()
|
| /external/mockito/src/test/java/org/mockitousage/serialization/ |
| D | ParallelSerializationTest.java | 28 final ExecutorService executorService = Executors.newFixedThreadPool(threadingFactor); in single_mock_being_serialized_in_different_classloaders_by_multiple_threads() local
41 futures.add(executorService.submit(new Callable<Object>() { in single_mock_being_serialized_in_different_classloaders_by_multiple_threads()
52 executorService.submit(new Callable<Object>() { in single_mock_being_serialized_in_different_classloaders_by_multiple_threads()
|
| /external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/badexecutor/ |
| D | BadExecutorTest.java | 31 ListeningExecutorService executorService = MoreExecutors.newDirectExecutorService(); in setUpComponent() local
34 .executor(executorService) in setUpComponent()
37 executorService.shutdown(); in setUpComponent()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| 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() {
|
| D | MoreExecutors.java | 672 */ static <T> T invokeAnyImpl(ListeningExecutorService executorService, in invokeAnyImpl() argument
675 checkNotNull(executorService); in invokeAnyImpl()
694 futures.add(submitAndAddQueueListener(executorService, it.next(), futureQueue)); in invokeAnyImpl()
703 futures.add(submitAndAddQueueListener(executorService, it.next(), futureQueue)); in invokeAnyImpl()
746 ListeningExecutorService executorService, Callable<T> task, in submitAndAddQueueListener() argument
748 final ListenableFuture<T> future = executorService.submit(task); in submitAndAddQueueListener()
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | ExecutionListBenchmark.java | 153 private ExecutorService executorService;
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/r8/src/test/java/com/android/tools/r8/ |
| D | R8UnreachableCodeTest.java | 34 ExecutorService executorService = Executors.newSingleThreadExecutor(); in UnreachableCode() local
37 new ApplicationReader(input, new InternalOptions(), timing).read(executorService); in UnreachableCode()
|
| /external/r8/src/test/java/com/android/tools/r8/internal/ |
| D | R8GMSCoreLookupTest.java | 38 ExecutorService executorService = Executors.newSingleThreadExecutor(); in readGMSCore() local
40 program = new ApplicationReader(app, new InternalOptions(), timing).read(executorService); in readGMSCore()
|
| /external/guava/guava-testlib/test/com/google/common/testing/ |
| D | FakeTickerTest.java | 150 ExecutorService executorService = Executors.newFixedThreadPool(numberOfThreads); in runConcurrentTest() local
154 executorService.submit(new Callable<Void>() { in runConcurrentTest()
|
| /external/glide/third_party/disklrucache/src/main/java/com/bumptech/glide/disklrucache/ |
| D | DiskLruCache.java | 158 final ThreadPoolExecutor executorService = field in DiskLruCache
430 executorService.submit(cleanupCallable); in get()
489 executorService.submit(cleanupCallable); in setMaxSize()
560 executorService.submit(cleanupCallable); in completeEdit()
605 executorService.submit(cleanupCallable); in remove()
|
| /external/guice/extensions/servlet/test/com/google/inject/servlet/ |
| D | ContinuingRequestIntegrationTest.java | 201 @Inject ExecutorService executorService; field in ContinuingRequestIntegrationTest.ContinuingServlet
214 executorService.submit(task); in doGet()
|
| /external/mockito/src/test/java/org/mockitoutil/ |
| D | ClassLoaders.java | 103 … ExecutorService executorService = Executors.newSingleThreadExecutor(new ThreadFactory() { in execute() local
112 Future<?> taskFuture = executorService.submit(new Runnable() { in execute()
126 executorService.shutdownNow(); in execute()
|
| /external/guice/core/test/com/google/inject/ |
| D | InjectorTest.java | 390 final ExecutorService executorService = Executors.newSingleThreadExecutor();
398 Future<JustInTime> future = executorService.submit(new Callable<JustInTime>() {
|
| /external/r8/src/main/java/com/android/tools/r8/shaking/ |
| D | RootSetBuilder.java | 204 public RootSet run(ExecutorService executorService) throws ExecutionException { in run() argument
223 futures.add(executorService.submit(() -> { in run()
|
| /external/r8/src/main/java/com/android/tools/r8/ir/conversion/ |
| D | IRConverter.java | 264 public DexApplication optimize(ExecutorService executorService) throws ExecutionException { in optimize() argument
289 futures.add(executorService.submit(() -> { in optimize()
|