Home
last modified time | relevance | path

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

123

/packages/modules/Uwb/generic_ranging/src/com/android/ranging/generic/ranging/
DUwbAdapter.java72 private final ListeningExecutorService executorService; field in UwbAdapter
97 this.executorService = executorServices; in UwbAdapter()
106 ListeningExecutorService executorService) { in UwbAdapter() argument
114 this.executorService = executorService; in UwbAdapter()
135 }, executorService); in isEnabled() field in UwbAdapter
182 }, executorService); in getLocalAddress()
196 }, executorService);
211 }, executorService);
227 uwbClient.get().startRanging(uwbListener, executorService);
228 }, executorService);
[all …]
/packages/apps/Dialer/java/com/android/voicemail/impl/transcribe/
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()
/packages/apps/Dialer/java/com/android/dialer/commandline/impl/
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()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/service/common/
DRetryStrategyFactory.java30 private RetryStrategyFactory(boolean isRetryStrategyEnabled, ExecutorService executorService) { in RetryStrategyFactory() argument
32 mExecutorService = executorService; in RetryStrategyFactory()
37 boolean isAdServicesRetryStrategyEnabled, ExecutorService executorService) { in createInstance() argument
38 return new RetryStrategyFactory(isAdServicesRetryStrategyEnabled, executorService); in createInstance()
DRetryStrategyImpl.java35 public RetryStrategyImpl(int numberOfRetryAttempts, @NonNull ExecutorService executorService) { in RetryStrategyImpl() argument
36 Objects.requireNonNull(executorService); in RetryStrategyImpl()
39 mExecutorService = executorService; in RetryStrategyImpl()
/packages/modules/Connectivity/service-t/src/com/android/server/connectivity/mdns/
DExecutorProvider.java59 public void shutdownExecutorService(@NonNull ScheduledExecutorService executorService) { in shutdownExecutorService() argument
60 if (!executorService.isShutdown()) { in shutdownExecutorService()
61 executorService.shutdownNow(); in shutdownExecutorService()
63 serviceTypeClientSchedulerExecutors.remove(executorService); in shutdownExecutorService()
/packages/modules/OnDevicePersonalization/tests/servicetests/src/com/android/ondevicepersonalization/services/
DOnDevicePersonalizationBroadcastReceiverTests.java88 ListeningExecutorService executorService = MoreExecutors.newDirectExecutorService(); in testOnReceive() local
89 MobileDataDownloadFactory.getMdd(mContext, executorService, executorService); in testOnReceive()
92 new OnDevicePersonalizationBroadcastReceiver(executorService); in testOnReceive()
131 ListeningExecutorService executorService = MoreExecutors.newDirectExecutorService(); in testOnReceiveKillSwitchOn() local
133 new OnDevicePersonalizationBroadcastReceiver(executorService); in testOnReceiveKillSwitchOn()
170 ListeningExecutorService executorService = MoreExecutors.newDirectExecutorService(); in testOnReceiveDeviceNotSupported() local
172 new OnDevicePersonalizationBroadcastReceiver(executorService); in testOnReceiveDeviceNotSupported()
/packages/apps/Dialer/java/com/android/dialer/phonelookup/blockednumber/
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()
/packages/modules/DeviceLock/DeviceLockController/src/com/android/devicelockcontroller/storage/
DSetupParametersClient.java54 ListeningExecutorService executorService) { in SetupParametersClient() argument
55 super(context, new ComponentName(context, SetupParametersService.class), executorService); in SetupParametersClient()
71 @Nullable ListeningExecutorService executorService) { in getInstance() argument
76 executorService == null in getInstance()
78 : executorService); in getInstance()
DGlobalParametersClient.java53 ListeningExecutorService executorService) { in GlobalParametersClient() argument
54 super(context, new ComponentName(context, GlobalParametersService.class), executorService); in GlobalParametersClient()
70 @Nullable ListeningExecutorService executorService) { in getInstance() argument
75 executorService == null in getInstance()
77 : executorService); in getInstance()
/packages/modules/DeviceLock/DeviceLockController/src/com/android/devicelockcontroller/provision/worker/
DIsDeviceInApprovedCountryWorker.java50 @NonNull WorkerParameters workerParams, ListeningExecutorService executorService) { in IsDeviceInApprovedCountryWorker() argument
51 super(context, workerParams, null, executorService); in IsDeviceInApprovedCountryWorker()
57 DeviceCheckInClient client, ListeningExecutorService executorService) { in IsDeviceInApprovedCountryWorker() argument
58 super(context, workerParameters, client, executorService); in IsDeviceInApprovedCountryWorker()
DReportDeviceLockProgramCompleteWorker.java55 @NonNull WorkerParameters workerParams, ListeningExecutorService executorService) { in ReportDeviceLockProgramCompleteWorker() argument
60 executorService); in ReportDeviceLockProgramCompleteWorker()
68 ListeningExecutorService executorService) { in ReportDeviceLockProgramCompleteWorker() argument
86 portNumber, clientInterceptor, id), executorService); in ReportDeviceLockProgramCompleteWorker()
DDeviceCheckInWorker.java55 @NonNull WorkerParameters workerParams, ListeningExecutorService executorService) { in DeviceCheckInWorker() argument
59 executorService); in DeviceCheckInWorker()
65 DeviceCheckInClient client, ListeningExecutorService executorService) { in DeviceCheckInWorker() argument
66 super(context, workerParameters, client, executorService); in DeviceCheckInWorker()
DPauseProvisioningWorker.java109 @NonNull WorkerParameters workerParams, ListeningExecutorService executorService) { in PauseProvisioningWorker() argument
110 this(context, workerParams, null, executorService); in PauseProvisioningWorker()
115 DeviceCheckInClient client, ListeningExecutorService executorService) { in PauseProvisioningWorker() argument
116 super(context, workerParams, client, executorService); in PauseProvisioningWorker()
/packages/inputmethods/LatinIME/java/src/com/android/inputmethod/latin/utils/
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()
/packages/modules/GeoTZ/data_pipeline/src/main/java/com/android/timezone/location/data_pipeline/steps/
DTzS2PolygonsToTzS2CellUnions.java68 File inputDir, ExecutorService executorService, File outputDir, int maxS2Level, in TzS2PolygonsToTzS2CellUnions() argument
71 this.mExecutorService = Objects.requireNonNull(executorService); in TzS2PolygonsToTzS2CellUnions()
122 ExecutorService executorService = Executors.newFixedThreadPool(threads); in main() local
124 new TzS2PolygonsToTzS2CellUnions(inputDir, executorService, outputDir, maxS2Level, in main()
131 executorService.shutdown(); in main()
132 executorService.awaitTermination(5, TimeUnit.SECONDS); in main()
DTzS2CellUnionsToTzS2Ranges.java66 File inputDir, ExecutorService executorService, File outputDir, int s2Level, in TzS2CellUnionsToTzS2Ranges() argument
69 this.mExecutorService = Objects.requireNonNull(executorService); in TzS2CellUnionsToTzS2Ranges()
120 ExecutorService executorService = Executors.newFixedThreadPool(threads); in main() local
122 new TzS2CellUnionsToTzS2Ranges(inputDir, executorService, outputDir, s2Level, in main()
129 executorService.shutdown(); in main()
130 executorService.awaitTermination(5, TimeUnit.SECONDS); in main()
DGeoJsonTzToTzS2Polygons.java82 File inputFile, ExecutorService executorService, File outputDir, in GeoJsonTzToTzS2Polygons() argument
86 this.mExecutorService = Objects.requireNonNull(executorService); in GeoJsonTzToTzS2Polygons()
142 ExecutorService executorService = Executors.newFixedThreadPool(threads); in main() local
145 inputFile, executorService, outputDir, protoStorageFormat, tzIds); in main()
151 executorService.shutdown(); in main()
152 executorService.awaitTermination(5, TimeUnit.SECONDS); in main()
DMergeTzS2Ranges.java64 File inputDir, ExecutorService executorService, File workingDir, File outputFile, in MergeTzS2Ranges() argument
67 this.mExecutorService = Objects.requireNonNull(executorService); in MergeTzS2Ranges()
114 ExecutorService executorService = Executors.newFixedThreadPool(threads); in main() local
117 inputDir, executorService, workingDir, outputFile, protoStorageFormat); in main()
123 executorService.shutdown(); in main()
124 executorService.awaitTermination(5, TimeUnit.SECONDS); in main()
/packages/modules/AdServices/adservices/service-core/java/com/android/adservices/cobalt/
DCobaltDataServiceFactory.java41 @NonNull Context context, @NonNull ExecutorService executorService) { in createDataService() argument
43 Objects.requireNonNull(executorService); in createDataService()
49 return new DataService(executorService, cobaltDatabase); in createDataService()
/packages/modules/OnDevicePersonalization/tests/servicetests/src/com/android/ondevicepersonalization/services/download/mdd/
DMobileDataDownloadFactoryTest.java39 ListeningExecutorService executorService = MoreExecutors.newDirectExecutorService(); in testSingletonInstance() local
41 .getMdd(mContext, executorService, executorService); in testSingletonInstance()
/packages/modules/AdServices/adservices/framework/java/android/adservices/common/
DAssetFileDescriptorUtil.java49 @NonNull byte[] buffer, @NonNull ExecutorService executorService) throws IOException { in setupAssetFileDescriptorResponse() argument
51 Objects.requireNonNull(executorService); in setupAssetFileDescriptorResponse()
56 executorService.execute( in setupAssetFileDescriptorResponse()
/packages/apps/Dialer/java/com/android/dialer/app/voicemail/
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()
/packages/modules/AppSearch/testing/appsindexertests/src/com/android/server/appsearch/appsindexer/
DTestUtils.java196 @NonNull Context context, @NonNull ExecutorService executorService) in removeFakePackageDocuments() argument
199 Objects.requireNonNull(executorService); in removeFakePackageDocuments()
205 executorService) in removeFakePackageDocuments()
250 @NonNull Context context, @NonNull ExecutorService executorService) in createFakeAppIndexerSession() argument
253 Objects.requireNonNull(executorService); in createFakeAppIndexerSession()
257 executorService) in createFakeAppIndexerSession()
/packages/modules/DeviceLock/DeviceLockController/src/com/android/devicelockcontroller/policy/
DStartLockTaskModeWorker.java63 ListeningExecutorService executorService) { in StartLockTaskModeWorker() argument
68 executorService); in StartLockTaskModeWorker()
77 ListeningExecutorService executorService) { in StartLockTaskModeWorker() argument
80 mExecutorService = executorService; in StartLockTaskModeWorker()

123