| /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()
|
| D | BatchingNamedTaskExecutor.java | 44 public BatchingNamedTaskExecutor(NamedTaskExecutor executor) { in BatchingNamedTaskExecutor() argument
45 mExecutor = executor; in BatchingNamedTaskExecutor()
|
| /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/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/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/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) {
|
| D | ExecutorCallback.java | 40 public ExecutorCallback(Callback<T> callback, Executor executor) { in ExecutorCallback() argument
42 mExecutor = executor; in ExecutorCallback()
|
| D | ForwardingObservable.java | 38 public SafeCloseable addCallback(Runnable callback, Executor executor) { in addCallback() argument
39 return mDelegate.addCallback(callback, executor); in addCallback()
|
| D | ResettingDelayedExecutor.java | 40 public ResettingDelayedExecutor(ScheduledExecutorService executor, long delay, TimeUnit in ResettingDelayedExecutor() argument
42 mExecutor = executor; in ResettingDelayedExecutor()
|
| /packages/apps/DocumentsUI/src/com/android/documentsui/services/ |
| D | FileOperationService.java | 100 @VisibleForTesting ExecutorService executor; field in FileOperationService
131 if (executor == null) { in onCreate()
132 executor = Executors.newFixedThreadPool(POOL_SIZE); in onCreate()
173 List<Runnable> unfinishedCopies = executor.shutdownNow(); in onDestroy()
183 executor = null; in onDestroy()
282 return executor; in getExecutorService()
|
| /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/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/inputmethods/LatinIME/tests/src/com/android/inputmethod/latin/utils/ |
| D | ExecutorUtilsTests.java | 38 final ExecutorService executor = in testExecute() local
42 executor.execute(new Runnable() { in testExecute()
50 executor.awaitTermination(DELAY_FOR_WAITING_TASKS_MILLISECONDS, TimeUnit.MILLISECONDS); in testExecute()
|
| /packages/apps/TV/src/com/android/tv/util/ |
| D | ImageLoader.java | 192 int maxWidth, int maxHeight, ImageLoaderCallback callback, Executor executor) { in doLoadBitmap() argument
203 return doLoadBitmap(callback, executor, in doLoadBitmap()
226 private static boolean doLoadBitmap(ImageLoaderCallback callback, Executor executor, in doLoadBitmap() argument
248 loadBitmapTask.executeOnExecutor(executor); in doLoadBitmap()
|
| /packages/apps/Contacts/src/com/android/contacts/util/concurrent/ |
| D | ContactsExecutors.java | 85 final ThreadPoolExecutor executor = new ThreadPoolExecutor( in getSimReadExecutor() local
87 executor.allowCoreThreadTimeOut(true); in getSimReadExecutor()
88 sSimExecutor = MoreExecutors.listeningDecorator(executor); in getSimReadExecutor()
|
| D | FuturesUtil.java | 39 TimeUnit unit, ScheduledExecutorService executor) { in withTimeout() argument
41 executor.schedule(new Runnable() { in withTimeout()
|
| /packages/apps/Camera2/src/com/android/camera/one/v2/commands/ |
| D | RunnableCameraCommand.java | 27 public RunnableCameraCommand(CameraCommandExecutor executor, CameraCommand command) { in RunnableCameraCommand() argument
28 mExecutor = executor; in RunnableCameraCommand()
|
| D | ResettingRunnableCameraCommand.java | 44 public ResettingRunnableCameraCommand(CameraCommandExecutor executor, CameraCommand command) { in ResettingRunnableCameraCommand() argument
45 mExecutor = executor; in ResettingRunnableCameraCommand()
|
| /packages/inputmethods/LatinIME/native/dicttoolkit/ |
| D | dict_toolkit_main.cpp | 37 const auto executor = CommandUtils::getCommandExecutor(commandType); in main() local
38 return executor(argc - 1, argv + 1); in main()
|
| /packages/apps/Launcher3/tests/src/com/android/launcher3/util/ |
| D | Condition.java | 19 final MainThreadExecutor executor = new MainThreadExecutor(); in runOnUiThread() local
26 executor.execute(new Runnable() { in runOnUiThread()
|
| /packages/apps/Dialer/java/com/android/dialer/common/concurrent/ |
| D | AsyncTaskExecutors.java | 81 public SimpleAsyncTaskExecutor(Executor executor) { in SimpleAsyncTaskExecutor() argument
82 mExecutor = executor; in SimpleAsyncTaskExecutor()
|
| /packages/providers/CalendarProvider/src/com/android/providers/calendar/ |
| D | CalendarReceiver.java | 39 private final ExecutorService executor = Executors.newCachedThreadPool(); field in CalendarReceiver
54 executor.submit(new Runnable() { in onReceive()
|
| /packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/ |
| D | PackageIconLoaderTest.java | 54 NamedTaskExecutor executor = new SingleThreadNamedTaskExecutor( in create() local
57 executor); in create()
|