Home
last modified time | relevance | path

Searched refs:executorService (Results 1 – 25 of 38) sorted by relevance

12

/aosp12/packages/apps/Dialer/java/com/android/voicemail/impl/transcribe/
H A DTranscriptionService.java53 private ExecutorService executorService; field in TranscriptionService
135 ExecutorService executorService, in TranscriptionService() argument
138 this.executorService = executorService; in TranscriptionService()
191 if (executorService != null) { in cleanup()
192 executorService.shutdownNow(); in cleanup()
193 executorService = null; in cleanup()
229 if (executorService == null) { in getExecutorService()
233 executorService = Executors.newSingleThreadExecutor(); in getExecutorService()
235 return executorService; in getExecutorService()
/aosp12/packages/apps/Dialer/java/com/android/dialer/commandline/impl/
H A DBlockingCommand.java54 private final ListeningExecutorService executorService; field in BlockingCommand
59 @BackgroundExecutor ListeningExecutorService executorService) { in BlockingCommand() argument
61 this.executorService = executorService; in BlockingCommand()
91 executorService.submit(() -> new DialerPhoneNumberUtil().parse(number, null)); in run()
100 executorService); in run()
/aosp12/packages/apps/Dialer/java/com/android/dialer/phonelookup/blockednumber/
H A DSystemBlockedNumberPhoneLookup.java54 private final ListeningExecutorService executorService; field in SystemBlockedNumberPhoneLookup
60 @BackgroundExecutor ListeningExecutorService executorService, in SystemBlockedNumberPhoneLookup() argument
63 this.executorService = executorService; in SystemBlockedNumberPhoneLookup()
72 return executorService.submit(() -> queryNumbers(ImmutableSet.of(number)).get(number)); in lookup()
89 return executorService.submit(() -> queryNumbers(existingInfoMap.keySet())); in getMostRecentInfo()
/aosp12/packages/inputmethods/LatinIME/java/src/com/android/inputmethod/latin/utils/
H A DExecutorUtils.java98 final ScheduledExecutorService executorService = getBackgroundExecutor(name); in killTasks() local
99 executorService.shutdownNow(); in killTasks()
101 executorService.awaitTermination(5, TimeUnit.SECONDS); in killTasks()
105 if (executorService == sExecutorServiceForTests) { in killTasks()
/aosp12/packages/modules/GeoTZ/data_pipeline/src/main/java/com/android/timezone/location/data_pipeline/steps/
H A DTzS2PolygonsToTzS2CellUnions.java68 File inputDir, ExecutorService executorService, File outputDir, int maxS2Level, in TzS2PolygonsToTzS2CellUnions() argument
71 this.mExecutorService = Objects.requireNonNull(executorService); in TzS2PolygonsToTzS2CellUnions()
123 ExecutorService executorService = Executors.newFixedThreadPool(threads); in main() local
125 new TzS2PolygonsToTzS2CellUnions(inputDir, executorService, outputDir, maxS2Level, in main()
132 executorService.shutdown(); in main()
133 executorService.awaitTermination(5, TimeUnit.SECONDS); in main()
H A DTzS2CellUnionsToTzS2Ranges.java66 File inputDir, ExecutorService executorService, File outputDir, int s2Level, in TzS2CellUnionsToTzS2Ranges() argument
69 this.mExecutorService = Objects.requireNonNull(executorService); in TzS2CellUnionsToTzS2Ranges()
121 ExecutorService executorService = Executors.newFixedThreadPool(threads); in main() local
123 new TzS2CellUnionsToTzS2Ranges(inputDir, executorService, outputDir, s2Level, in main()
130 executorService.shutdown(); in main()
131 executorService.awaitTermination(5, TimeUnit.SECONDS); in main()
H A DGeoJsonTzToTzS2Polygons.java81 File inputFile, ExecutorService executorService, File outputDir, in GeoJsonTzToTzS2Polygons() argument
85 this.mExecutorService = Objects.requireNonNull(executorService); in GeoJsonTzToTzS2Polygons()
141 ExecutorService executorService = Executors.newFixedThreadPool(threads); in main() local
144 inputFile, executorService, outputDir, protoStorageFormat, tzIds); in main()
150 executorService.shutdown(); in main()
151 executorService.awaitTermination(5, TimeUnit.SECONDS); in main()
H A DMergeTzS2Ranges.java64 File inputDir, ExecutorService executorService, File workingDir, File outputFile, in MergeTzS2Ranges() argument
67 this.mExecutorService = Objects.requireNonNull(executorService); in MergeTzS2Ranges()
115 ExecutorService executorService = Executors.newFixedThreadPool(threads); in main() local
118 inputDir, executorService, workingDir, outputFile, protoStorageFormat); in main()
124 executorService.shutdown(); in main()
125 executorService.awaitTermination(5, TimeUnit.SECONDS); in main()
/aosp12/frameworks/base/services/core/java/com/android/server/apphibernation/
H A DHibernationStateDiskStore.java67 @NonNull ScheduledExecutorService executorService) { in HibernationStateDiskStore() argument
68 this(hibernationDir, readWriter, executorService, STATES_FILE_NAME); in HibernationStateDiskStore()
74 @NonNull ScheduledExecutorService executorService, in HibernationStateDiskStore() argument
77 mExecutorService = executorService; in HibernationStateDiskStore()
/aosp12/packages/apps/Dialer/java/com/android/dialer/app/voicemail/
H A DVoicemailPlaybackLayout.java241 public void onPlaybackStarted(int duration, ScheduledExecutorService executorService) { in onPlaybackStarted() argument
250 positionUpdater = new PositionUpdater(duration, executorService); in onPlaybackStarted()
383 private final ScheduledExecutorService executorService; field in VoicemailPlaybackLayout.PositionUpdater
406 public PositionUpdater(int durationMs, ScheduledExecutorService executorService) { in PositionUpdater() argument
408 this.executorService = executorService; in PositionUpdater()
420 executorService.scheduleAtFixedRate( in startUpdating()
/aosp12/packages/services/Telephony/tests/src/com/android/phone/callcomposer/
H A DPictureManagerTest.java110 String url, ExecutorService executorService) { in testPictureUpload()
168 String url, ExecutorService executorService) { in testPictureUploadWithAuthRefresh()
207 String url, ExecutorService executorService) { in testPictureDownload()
246 String url, ExecutorService executorService) { in testPictureDownloadWithAuthRefresh()
312 ExecutorService executorService, long timeoutMillis) { in waitForExecutorAction() argument
314 executorService.execute(() -> f.complete(null)); in waitForExecutorAction()
/aosp12/packages/services/Telephony/src/com/android/services/telephony/rcs/
H A DSipDelegateController.java94 ScheduledExecutorService executorService, in SipDelegateController() argument
100 mExecutorService = executorService; in SipDelegateController()
103 mMessageTransportWrapper = new MessageTransportWrapper(mSubId, executorService, in SipDelegateController()
114 ScheduledExecutorService executorService, in SipDelegateController() argument
121 mExecutorService = executorService; in SipDelegateController()
/aosp12/art/test/708-jit-cache-churn/src/
H A DJitCacheChurnTest.java59 private final ExecutorService executorService; field in JitCacheChurnTest
63 this.executorService = new ThreadPoolExecutor(CONCURRENCY, CONCURRENCY, 5000, in JitCacheChurnTest()
68 this.executorService.shutdown(); in shutdown()
82 List<Future<Integer>> results = executorService.invokeAll(tasks); in runTasks()
/aosp12/packages/apps/Dialer/java/com/android/dialer/common/concurrent/
H A DDefaultDialerExecutorFactory.java196 @NonNull ExecutorService executorService, @Nullable InputT input) { in executeOnCustomExecutorService()
197 dialerUiTaskFragment.executeOnCustomExecutor(Assert.isNotNull(executorService), input); in executeOnCustomExecutorService()
247 @NonNull ExecutorService executorService, @Nullable InputT input) { in executeOnCustomExecutorService()
248 Assert.isNotNull(executorService).execute(() -> run(input)); in executeOnCustomExecutorService()
H A DDialerExecutor.java197 @NonNull ExecutorService executorService, @Nullable InputT input); in executeOnCustomExecutorService()
/aosp12/frameworks/layoutlib/bridge/tests/src/com/android/layoutlib/bridge/intensive/util/perf/
H A DTimedStatement.java145 ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1); in evaluate() local
147 executorService.scheduleAtFixedRate(() -> { in evaluate()
166 executorService.shutdownNow(); in evaluate()
/aosp12/frameworks/base/services/tests/servicestests/src/com/android/server/pm/
H A DParallelPackageParserTest.java79 TestParallelPackageParser(PackageParser2 packageParser, ExecutorService executorService) { in TestParallelPackageParser() argument
80 super(packageParser, executorService); in TestParallelPackageParser()
/aosp12/frameworks/base/services/core/java/com/android/server/pm/
H A DParallelPackageParser.java58 ParallelPackageParser(PackageParser2 packageParser, ExecutorService executorService) { in ParallelPackageParser() argument
60 mExecutorService = executorService; in ParallelPackageParser()
H A DApexManager.java154 @NonNull ExecutorService executorService); in scanApexPackagesTraced() argument
511 @NonNull ExecutorService executorService) { in scanApexPackagesTraced() argument
515 scanApexPackagesInternalLocked(packageParser, executorService); in scanApexPackagesTraced()
524 ExecutorService executorService) { in scanApexPackagesInternalLocked() argument
542 new ParallelPackageParser(packageParser, executorService); in scanApexPackagesInternalLocked()
1194 @NonNull ExecutorService executorService) { in scanApexPackagesTraced() argument
/aosp12/packages/apps/SettingsIntelligence/src/com/android/settings/intelligence/search/
H A DSearchResultAggregator.java52 final ExecutorService executorService = mFeatureProvider.getExecutorService(); in fetchResults() local
58 executorService.execute(task); in fetchResults()
/aosp12/packages/services/Telephony/testapps/TestRcsApp/aosp_test_rcsclient/src/com/android/libraries/rcs/simpleclient/provisioning/
H A DStaticConfigProvisioningController.java46 private final ExecutorService executorService = Executors.newSingleThreadExecutor(); field in StaticConfigProvisioningController
147 provisioningManager.registerRcsProvisioningCallback(executorService, callback); in register()
/aosp12/frameworks/base/packages/BackupEncryption/src/com/android/server/backup/encryption/tasks/
H A DEncryptedFullBackupDataProcessor.java65 ExecutorService executorService, in EncryptedFullBackupDataProcessor() argument
71 mExecutorService = Objects.requireNonNull(executorService); in EncryptedFullBackupDataProcessor()
/aosp12/frameworks/base/core/java/android/os/
H A DBinderProxy.java272 ExecutorService executorService = Executors.newSingleThreadExecutor(); in getSortedInterfaceCounts() local
273 executorService.submit(() -> { in getSortedInterfaceCounts()
299 executorService.shutdown(); in getSortedInterfaceCounts()
300 boolean dumpDone = executorService.awaitTermination(20, TimeUnit.SECONDS); in getSortedInterfaceCounts()
/aosp12/packages/services/Telephony/src/com/android/phone/callcomposer/
H A DCallComposerPictureTransfer.java79 ExecutorService executorService) { in create() argument
80 return new CallComposerPictureTransfer(context, subscriptionId, url, executorService); in create()
107 ExecutorService executorService) { in CallComposerPictureTransfer() argument
110 mExecutorService = executorService; in CallComposerPictureTransfer()
/aosp12/packages/apps/SettingsIntelligence/src/com/android/settings/intelligence/search/query/
H A DDatabaseResultTask.java134 ExecutorService executorService = mFeatureProvider.getExecutorService(); in query() local
135 executorService.execute(rankerTask); in query()

12