| /packages/apps/TV/src/com/android/tv/util/ |
| D | AsyncDbTask.java | 86 @DbExecutor Executor executor, in AsyncQueryTask()
93 super(executor); in AsyncQueryTask()
197 Executor executor, in AsyncQueryListTask() argument
204 this(executor, context, uri, projection, selection, selectionArgs, orderBy, null); in AsyncQueryListTask()
208 Executor executor, in AsyncQueryListTask() argument
216 super(executor, context, uri, projection, selection, selectionArgs, orderBy); in AsyncQueryListTask()
262 Executor executor, in AsyncQueryItemTask() argument
269 super(executor, context, uri, projection, selection, selectionArgs, orderBy); in AsyncQueryItemTask()
309 public AsyncChannelQueryTask(Executor executor, Context context) { in AsyncChannelQueryTask() argument
311 executor, in AsyncChannelQueryTask()
[all …]
|
| /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 | 84 Executor executor; in VmsSubscriberManager()
86 executor = mExecutor; in VmsSubscriberManager()
88 if (executor == null) { in VmsSubscriberManager()
95 executor.execute(() -> { in VmsSubscriberManager()
102 Executor executor; in VmsSubscriberManager()
104 executor = mExecutor; in VmsSubscriberManager()
106 if (executor == null) { in VmsSubscriberManager()
113 executor.execute(() -> { in VmsSubscriberManager()
128 @NonNull @CallbackExecutor Executor executor, in setVmsSubscriberClientCallback()
136 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/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()
289 protected void executeCallbacksTask(CallbackTask task, Executor executor) { in executeCallbacksTask() argument
290 executor.execute(() -> { in executeCallbacksTask()
|
| /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()
816 KeyEventHandlerRecord(@NonNull Executor executor, @NonNull BitSet subscribedEvents) { in KeyEventHandlerRecord() argument
817 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/Email/emailcommon/src/com/android/emailcommon/utility/ |
| D | EmailAsyncTask.java | 218 private EmailAsyncTask<Params, Progress, Result> executeInternal(Executor executor, in executeInternal() argument
227 mInnerTask.executeOnExecutor(executor, params); in executeInternal()
245 private static EmailAsyncTask<Void, Void, Void> runAsyncInternal(Executor executor, in runAsyncInternal() argument
254 return task.executeInternal(executor, false, (Void[]) null); in runAsyncInternal()
|
| /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/services/Car/tests/CarDeveloperOptions/src/com/android/car/developeroptions/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()
|
| /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()
|
| /packages/apps/TV/src/com/android/tv/util/images/ |
| D | ImageLoader.java | 200 Executor executor) { in doLoadBitmap() argument
213 executor, in doLoadBitmap()
235 ImageLoaderCallback callback, Executor executor, LoadBitmapTask loadBitmapTask) { in doLoadBitmap() argument
256 loadBitmapTask.executeOnExecutor(executor); in doLoadBitmap()
|
| /packages/apps/DocumentsUI/src/com/android/documentsui/inspector/ |
| D | DebugView.java | 97 Executor executor = mExecutors.lookup(info.derivedUri.getAuthority()); in accept() local
98 if (executor != null) { in accept()
110 }.executeOnExecutor(executor, (Void[]) null); in accept()
|