/packages/apps/TV/src/com/android/tv/util/ |
D | AsyncDbTask.java | 91 @DbExecutor Executor executor, in AsyncQueryTask() 98 super(executor); in AsyncQueryTask() 202 Executor executor, in AsyncQueryListTask() argument 209 this(executor, context, uri, projection, selection, selectionArgs, orderBy, null); in AsyncQueryListTask() 213 Executor executor, in AsyncQueryListTask() argument 221 super(executor, context, uri, projection, selection, selectionArgs, orderBy); in AsyncQueryListTask() 267 Executor executor, in AsyncQueryItemTask() argument 274 super(executor, context, uri, projection, selection, selectionArgs, orderBy); in AsyncQueryItemTask() 314 public AsyncChannelQueryTask(Executor executor, Context context) { in AsyncChannelQueryTask() argument 316 executor, in AsyncChannelQueryTask() [all …]
|
/packages/services/Car/service/src/com/android/car/systeminterface/ |
D | TimeInterface.java | 55 ScheduledExecutorService executor; in scheduleAction() local 57 executor = mExecutor; in scheduleAction() 58 if (executor == null) { in scheduleAction() 59 executor = newSingleThreadScheduledExecutor(); in scheduleAction() 60 mExecutor = executor; in scheduleAction() 63 executor.scheduleAtFixedRate(r, delayMs, delayMs, TimeUnit.MILLISECONDS); in scheduleAction() 68 ScheduledExecutorService executor; in cancelAllActions() local 70 executor = mExecutor; in cancelAllActions() 73 if (executor != null) { in cancelAllActions() 74 executor.shutdownNow(); in cancelAllActions()
|
/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
D | PerNameExecutor.java | 39 for (NamedTaskExecutor executor : mExecutors.values()) { in cancelPendingTasks() 40 executor.cancelPendingTasks(); in cancelPendingTasks() 46 for (NamedTaskExecutor executor : mExecutors.values()) { in close() 47 executor.close(); in close() 56 NamedTaskExecutor executor = mExecutors.get(name); in execute() local 57 if (executor == null) { in execute() 58 executor = mExecutorFactory.create(); in execute() 59 mExecutors.put(name, executor); in execute() 61 executor.execute(task); in execute()
|
/packages/services/Car/car-lib/src/android/car/vms/ |
D | VmsSubscriberManager.java | 90 Executor executor; in VmsSubscriberManager() 92 executor = mExecutor; in VmsSubscriberManager() 94 if (executor == null) { in VmsSubscriberManager() 99 executor.execute(() -> { in VmsSubscriberManager() 106 Executor executor; in VmsSubscriberManager() 108 executor = mExecutor; in VmsSubscriberManager() 110 if (executor == null) { in VmsSubscriberManager() 115 executor.execute(() -> { in VmsSubscriberManager() 130 @NonNull @CallbackExecutor Executor executor, in setVmsSubscriberClientCallback() 138 mExecutor = Preconditions.checkNotNull(executor, "executor cannot be null"); in setVmsSubscriberClientCallback()
|
/packages/apps/Dialer/java/com/android/incallui/ringtone/ |
D | InCallTonePlayer.java | 40 @NonNull private final PausableExecutor executor; field in InCallTonePlayer 53 @NonNull ToneGeneratorFactory toneGeneratorFactory, @NonNull PausableExecutor executor) { in InCallTonePlayer() argument 55 this.executor = Objects.requireNonNull(executor); in InCallTonePlayer() 76 executor.execute( in play() 115 executor.milestone(); in playOnBackgroundThread() 119 executor.milestone(); in playOnBackgroundThread() 131 executor.milestone(); in playOnBackgroundThread()
|
/packages/apps/UniversalMediaPlayer/java/com/android/pump/util/ |
D | ImageLoader.java | 55 public ImageLoader(@NonNull Executor executor) { in ImageLoader() argument 56 mExecutor = executor; in ImageLoader() 63 public void addCallback(@NonNull Callback callback, @NonNull Executor executor) { in addCallback() argument 65 if (!mCallbacks.add(new SimpleEntry<>(executor, callback))) { in addCallback() 75 public void removeCallback(@NonNull Callback callback, @NonNull Executor executor) { in removeCallback() argument 77 if (!mCallbacks.remove(new SimpleEntry<>(executor, callback))) { in removeCallback() 88 @NonNull Executor executor) { in loadImage() argument 100 callbacks.add(new SimpleEntry<>(executor, callback)); in loadImage() 104 executor.execute(() -> callback.onImageLoaded(uri, bitmap)); in loadImage()
|
/packages/apps/DocumentsUI/src/com/android/documentsui/ |
D | ProviderExecutor.java | 36 ProviderExecutor executor = sExecutors.get(authority); in forAuthority() local 37 if (executor == null) { in forAuthority() 38 executor = new ProviderExecutor(); in forAuthority() 39 executor.setName("ProviderExecutor: " + authority); in forAuthority() 40 executor.start(); in forAuthority() 41 sExecutors.put(authority, executor); in forAuthority() 43 return executor; in forAuthority()
|
/packages/apps/Camera2/src/com/android/camera/processing/imagebackend/ |
D | ImageBackend.java | 250 public void releaseSemaphoreReference(final ImageToProcess img, Executor executor) { in releaseSemaphoreReference() argument 273 closeImageExecutorSafe(img, executor); in releaseSemaphoreReference() 482 public boolean receiveImage(ImageToProcess img, Executor executor, in receiveImage() argument 504 tasksToExecute.add(new TaskPreviewChainedJpeg(img, executor, this, session, in receiveImage() 509 tasksToExecute.add(new TaskCompressImageToJpeg(img, executor, this, session, in receiveImage() 516 tasksToExecute.add(new TaskConvertImageToRGBPreview(img, executor, in receiveImage() 555 ImageToProcess image, Executor executor, ImageBackend imageBackend, in createTaskConvertImageToRGBPreview() argument 558 return new TaskConvertImageToRGBPreview(image, executor, imageBackend, in createTaskConvertImageToRGBPreview() 564 Executor executor, ImageBackend imageBackend, CaptureSession session) { in createTaskCompressImageToJpeg() argument 565 return new TaskCompressImageToJpeg(image, executor, imageBackend, session, in createTaskCompressImageToJpeg() [all …]
|
/packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
D | MockNamedTaskExecutorFactory.java | 33 for (MockNamedTaskExecutor executor : mExecutors) { in runNext() 34 executor.runNext(); in runNext() 39 MockNamedTaskExecutor executor = new MockNamedTaskExecutor(); in create() local 40 mExecutors.add(executor); in create() 41 return executor; in create()
|
/packages/apps/Dialer/java/com/android/dialer/common/concurrent/ |
D | AsyncTaskExecutors.java | 79 private final Executor executor; field in AsyncTaskExecutors.SimpleAsyncTaskExecutor 81 public SimpleAsyncTaskExecutor(Executor executor) { in SimpleAsyncTaskExecutor() argument 82 this.executor = executor; in SimpleAsyncTaskExecutor() 89 return task.executeOnExecutor(executor, params); in submit()
|
D | DialerFutureSerializer.java | 42 public <T> ListenableFuture<T> submit(final Callable<T> callable, Executor executor) { in submit() argument 43 return submitAsync(() -> immediateFuture(callable.call()), executor); in submit() 53 public <T> ListenableFuture<T> submitAsync(final AsyncCallable<T> callable, Executor executor) { in submitAsync() argument 78 Futures.submitAsync(task, runnable -> oldFuture.addListener(runnable, executor))); in submitAsync()
|
/packages/apps/PermissionController/src/com/android/packageinstaller/role/ui/ |
D | ManageRoleHolderStateLiveData.java | 84 Executor executor = context.getMainExecutor(); in setRoleHolderAsUser() local 102 roleManager.addRoleHolderAsUser(roleName, packageName, flags, user, executor, callback); in setRoleHolderAsUser() 104 roleManager.removeRoleHolderAsUser(roleName, packageName, flags, user, executor, in setRoleHolderAsUser() 134 Executor executor = context.getMainExecutor(); in clearRoleHoldersAsUser() local 148 roleManager.clearRoleHoldersAsUser(roleName, flags, user, executor, callback); in clearRoleHoldersAsUser()
|
/packages/apps/Car/libs/connected-device-lib/src/com/android/car/connecteddevice/util/ |
D | ThreadSafeCallbacks.java | 36 public void add(@NonNull T callback, @NonNull @CallbackExecutor Executor executor) { in add() argument 37 mCallbacks.put(callback, executor); in add() 57 mCallbacks.forEach((callback, executor) -> in invoke() 58 executor.execute(() -> notification.accept(callback))); in invoke()
|
/packages/apps/Camera2/src/com/android/camera/async/ |
D | ConcurrentState.java | 37 public ExecutorListenerPair(Executor executor, Runnable listener) { in ExecutorListenerPair() argument 38 mExecutor = executor; in ExecutorListenerPair() 76 public SafeCloseable addCallback(Runnable callback, Executor executor) { in addCallback() argument 77 final ExecutorListenerPair pair = new ExecutorListenerPair(executor, callback); in addCallback()
|
D | Observables.java | 63 public SafeCloseable addCallback(Runnable callback, Executor executor) { in transform() argument 64 return input.addCallback(callback, executor); in transform() 102 public SafeCloseable addCallback(Runnable callback, Executor executor) {
|
/packages/apps/Launcher3/src/com/android/launcher3/model/ |
D | BaseLoaderResults.java | 256 final Executor executor) { in bindWorkspaceItems() argument 264 executor); in bindWorkspaceItems() 268 private void bindAppWidgets(ArrayList<LauncherAppWidgetInfo> appWidgets, Executor executor) { in bindAppWidgets() argument 274 c -> c.bindItems(Collections.singletonList(widget), false), executor); in bindAppWidgets() 288 protected void executeCallbacksTask(CallbackTask task, Executor executor) { in executeCallbacksTask() argument 289 executor.execute(() -> { in executeCallbacksTask()
|
/packages/apps/Settings/src/com/android/settings/network/ims/ |
D | ImsQueryController.java | 76 final ExecutorService executor = Executors.newSingleThreadExecutor(); in isEnabledByPlatform() local 78 imsMmTelManager.isSupported(mCapability, mTransportType, executor, booleanResult); in isEnabledByPlatform() 102 final ExecutorService executor = Executors.newSingleThreadExecutor(); in isServiceStateReady() local 104 imsMmTelManager.getFeatureState(executor, intResult); in isServiceStateReady()
|
/packages/apps/Car/libs/connected-device-lib/src/com/android/car/connecteddevice/ |
D | ConnectedDeviceManager.java | 240 @NonNull @CallbackExecutor Executor executor) { in registerDeviceAssociationCallback() argument 241 mDeviceAssociationCallbacks.add(callback, executor); in registerDeviceAssociationCallback() 261 @NonNull @CallbackExecutor Executor executor) { in registerActiveUserConnectionCallback() argument 262 mActiveUserConnectionCallbacks.add(callback, executor); in registerActiveUserConnectionCallback() 408 @NonNull DeviceCallback callback, @NonNull @CallbackExecutor Executor executor) { in registerDeviceCallback() argument 410 notifyOfBlacklisting(device, recipientId, callback, executor); in registerDeviceCallback() 424 notifyOfBlacklisting(device, recipientId, callback, executor); in registerDeviceCallback() 429 newCallbacks.add(callback, executor); in registerDeviceCallback() 449 @NonNull DeviceCallback callback, @NonNull Executor executor) { in notifyOfBlacklisting() argument 452 executor.execute(() -> in notifyOfBlacklisting()
|
/packages/apps/Camera2/src/com/android/camera/settings/ |
D | SettingObserver.java | 38 private Listener(Runnable runnable, Executor executor) { in Listener() argument 40 mExecutor = executor; in Listener() 87 public SafeCloseable addCallback(@Nonnull Runnable callback, @Nonnull Executor executor) { in addCallback() argument 88 Listener listener = new Listener(callback, executor); in addCallback()
|
/packages/apps/DocumentsUI/src/com/android/documentsui/services/ |
D | FileOperationService.java | 109 @VisibleForTesting ExecutorService executor; field in FileOperationService 141 if (executor == null) { in onCreate() 142 executor = Executors.newFixedThreadPool(POOL_SIZE); in onCreate() 188 List<Runnable> unfinishedCopies = executor.shutdownNow(); in onDestroy() 198 executor = null; in onDestroy() 306 return executor; in getExecutorService()
|
/packages/services/Car/car-lib/src/android/car/ |
D | CarProjectionManager.java | 382 @CallbackExecutor @Nullable Executor executor, in addKeyEventHandler() argument 395 if (executor == null) { in addKeyEventHandler() 396 executor = mHandlerExecutor; in addKeyEventHandler() 402 record = new KeyEventHandlerRecord(executor, eventMask); in addKeyEventHandler() 405 record.mExecutor = executor; in addKeyEventHandler() 817 KeyEventHandlerRecord(@NonNull Executor executor, @NonNull BitSet subscribedEvents) { in KeyEventHandlerRecord() argument 818 mExecutor = executor; in KeyEventHandlerRecord()
|
/packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/latin/utils/ |
D | ExecutorUtilsTests.java | 46 final ExecutorService executor = in testExecute() local 50 executor.execute(new Runnable() { in testExecute() 58 executor.awaitTermination(DELAY_FOR_WAITING_TASKS_MILLISECONDS, TimeUnit.MILLISECONDS); in testExecute()
|
/packages/apps/Messaging/src/android/support/v7/mms/ |
D | MmsService.java | 304 for (ExecutorService executor : mExecutors) { in onDestroy() 305 executor.shutdown(); in onDestroy() 382 final ExecutorService executor = getRequestExecutor(request); in retainService() local 384 executor.execute(runnable); in retainService()
|
/packages/apps/Launcher3/robolectric_tests/src/com/android/launcher3/model/ |
D | AddWorkspaceItemsTaskTest.java | 146 ExecutorService executor = Executors.newSingleThreadExecutor(); in setupWorkspaceWithHoles() local 162 executor.execute(() -> { in setupWorkspaceWithHoles() 172 executor.submit(() -> null).get(); in setupWorkspaceWithHoles() 173 executor.shutdown(); in setupWorkspaceWithHoles()
|
/packages/apps/Settings/src/com/android/settings/applications/appinfo/ |
D | DefaultAppShortcutPreferenceControllerBase.java | 63 final Executor executor = mContext.getMainExecutor(); in DefaultAppShortcutPreferenceControllerBase() local 64 roleControllerManager.isRoleVisible(mRoleName, executor, visible -> { in DefaultAppShortcutPreferenceControllerBase() 68 roleControllerManager.isApplicationQualifiedForRole(mRoleName, mPackageName, executor, in DefaultAppShortcutPreferenceControllerBase()
|