/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()
|