Home
last modified time | relevance | path

Searched refs:executor (Results 1 – 25 of 107) sorted by relevance

12345

/packages/apps/TV/src/com/android/tv/util/
DAsyncDbTask.java91 @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/
DTimeInterface.java55 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/
DPerNameExecutor.java39 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/
DVmsSubscriberManager.java90 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/
DInCallTonePlayer.java40 @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/
DImageLoader.java55 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/
DProviderExecutor.java36 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/
DImageBackend.java250 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/
DMockNamedTaskExecutorFactory.java33 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/
DAsyncTaskExecutors.java79 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()
DDialerFutureSerializer.java42 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/
DManageRoleHolderStateLiveData.java84 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/
DThreadSafeCallbacks.java36 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/
DConcurrentState.java37 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()
DObservables.java63 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/
DBaseLoaderResults.java256 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/
DImsQueryController.java76 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/
DConnectedDeviceManager.java240 @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/
DSettingObserver.java38 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/
DFileOperationService.java109 @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/
DCarProjectionManager.java382 @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/
DExecutorUtilsTests.java46 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/
DMmsService.java304 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/
DAddWorkspaceItemsTaskTest.java146 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/
DDefaultAppShortcutPreferenceControllerBase.java63 final Executor executor = mContext.getMainExecutor(); in DefaultAppShortcutPreferenceControllerBase() local
64 roleControllerManager.isRoleVisible(mRoleName, executor, visible -> { in DefaultAppShortcutPreferenceControllerBase()
68 roleControllerManager.isApplicationQualifiedForRole(mRoleName, mPackageName, executor, in DefaultAppShortcutPreferenceControllerBase()

12345