Searched refs:executor (Results 1 - 25 of 41) sorted by relevance

12

/packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/
H A DMockNamedTaskExecutorFactory.java30 * Runs one task in each executor.
33 for (MockNamedTaskExecutor executor : mExecutors) {
34 executor.runNext();
39 MockNamedTaskExecutor executor = new MockNamedTaskExecutor();
40 mExecutors.add(executor);
41 return executor;
/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/
H A DPerNameExecutor.java23 * Uses a separate executor for each task name.
39 for (NamedTaskExecutor executor : mExecutors.values()) {
40 executor.cancelPendingTasks();
46 for (NamedTaskExecutor executor : mExecutors.values()) {
47 executor.close();
56 NamedTaskExecutor executor = mExecutors.get(name);
57 if (executor == null) {
58 executor = mExecutorFactory.create();
59 mExecutors.put(name, executor);
61 executor
[all...]
H A DBatchingNamedTaskExecutor.java42 * @param executor A SourceTaskExecutor for actually executing the tasks.
44 public BatchingNamedTaskExecutor(NamedTaskExecutor executor) { argument
45 mExecutor = executor;
61 * Instructs the executor to submit the next batch of results.
80 * Cancel any unstarted tasks running in this executor. This instance
/packages/apps/Camera2/src/com/android/camera/one/v2/commands/
H A DRunnableCameraCommand.java27 public RunnableCameraCommand(CameraCommandExecutor executor, CameraCommand command) { argument
28 mExecutor = executor;
H A DResettingRunnableCameraCommand.java44 public ResettingRunnableCameraCommand(CameraCommandExecutor executor, CameraCommand command) { argument
45 mExecutor = executor;
/packages/inputmethods/LatinIME/native/dicttoolkit/
H A Ddict_toolkit_main.cpp37 const auto executor = CommandUtils::getCommandExecutor(commandType); local
38 return executor(argc - 1, argv + 1);
/packages/inputmethods/LatinIME/tests/src/com/android/inputmethod/latin/utils/
H A DExecutorUtilsTests.java38 final ExecutorService executor =
42 executor.execute(new Runnable() {
50 executor.awaitTermination(DELAY_FOR_WAITING_TASKS_MILLISECONDS, TimeUnit.MILLISECONDS);
/packages/apps/Camera2/src/com/android/camera/async/
H A DExecutorCallback.java28 * which runs it on an executor.
38 * @param executor The executor on which to invoke the callback.
40 public ExecutorCallback(Callback<T> callback, Executor executor) { argument
42 mExecutor = executor;
H A DForwardingObservable.java38 public SafeCloseable addCallback(Runnable callback, Executor executor) { argument
39 return mDelegate.addCallback(callback, executor);
H A DConcurrentState.java37 public ExecutorListenerPair(Executor executor, Runnable listener) { argument
38 mExecutor = executor;
43 * Runs the callback on the executor.
76 public SafeCloseable addCallback(Runnable callback, Executor executor) { argument
77 final ExecutorListenerPair pair = new ExecutorListenerPair(executor, callback);
H A DResettingDelayedExecutor.java25 * An executor which executes with a delay, discarding pending executions such
40 public ResettingDelayedExecutor(ScheduledExecutorService executor, long delay, TimeUnit argument
42 mExecutor = executor;
H A DObservables.java63 public SafeCloseable addCallback(Runnable callback, Executor executor) {
64 return input.addCallback(callback, executor);
102 public SafeCloseable addCallback(Runnable callback, Executor executor) {
H A DObservable.java42 * @param executor The executor on which the callback will be invoked.
47 public SafeCloseable addCallback(Runnable callback, Executor executor); argument
H A DObservableCombiner.java84 public SafeCloseable addCallback(Runnable callback, Executor executor) { argument
88 callbackLifetime.add(input.addCallback(callback, executor));
/packages/apps/Camera2/src/com/android/camera/processing/imagebackend/
H A DImageTaskManager.java58 * @param executor the executor on which the image close is run. if null,
62 public void releaseSemaphoreReference(final ImageToProcess img, Executor executor); argument
H A DTaskPreviewChainedJpeg.java39 * @param executor Executor to fire off an events
46 Executor executor,
51 super(image, executor, imageTaskManager, ProcessingPriority.AVERAGE, captureSession,
45 TaskPreviewChainedJpeg(ImageToProcess image, Executor executor, ImageTaskManager imageTaskManager, CaptureSession captureSession, Size targetSize, LruResourcePool<Integer, ByteBuffer> byteBufferResourcePool) argument
H A DImageBackend.java245 * @param executor the executor on which the image close is run. if null,
250 public void releaseSemaphoreReference(final ImageToProcess img, Executor executor) { argument
273 closeImageExecutorSafe(img, executor);
468 * @param executor Executor to run events and image closes, in case of
482 public boolean receiveImage(ImageToProcess img, Executor executor, argument
504 tasksToExecute.add(new TaskPreviewChainedJpeg(img, executor, this, session,
509 tasksToExecute.add(new TaskCompressImageToJpeg(img, executor, this, session,
516 tasksToExecute.add(new TaskConvertImageToRGBPreview(img, executor,
555 ImageToProcess image, Executor executor, ImageBacken
554 createTaskConvertImageToRGBPreview( ImageToProcess image, Executor executor, ImageBackend imageBackend, CaptureSession session, Size targetSize, TaskConvertImageToRGBPreview.ThumbnailShape thumbnailShape) argument
563 createTaskCompressImageToJpeg(ImageToProcess image, Executor executor, ImageBackend imageBackend, CaptureSession session) argument
759 closeImageExecutorSafe(final ImageToProcess img, Executor executor) argument
[all...]
H A DTaskChainedCompressImageToJpeg.java40 TaskChainedCompressImageToJpeg(ImageToProcess image, Executor executor, argument
42 super(image, executor, imageTaskManager, ProcessingPriority.SLOW, captureSession);
/packages/apps/Camera2/src/com/android/camera/settings/
H A DSettingObserver.java38 private Listener(Runnable runnable, Executor executor) { argument
40 mExecutor = executor;
87 public SafeCloseable addCallback(@Nonnull Runnable callback, @Nonnull Executor executor) { argument
88 Listener listener = new Listener(callback, executor);
/packages/apps/Dialer/src/com/android/dialer/util/
H A DAsyncTaskExecutors.java89 public SimpleAsyncTaskExecutor(Executor executor) { argument
90 mExecutor = executor;
/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/
H A DQueryTask.java79 NamedTaskExecutor executor, Handler handler,
84 executor.execute(task);
76 startQuery(String query, int maxResults, SuggestionCursorProvider<C> provider, NamedTaskExecutor executor, Handler handler, Consumer<C> consumer) argument
/packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/
H A DPackageIconLoaderTest.java54 NamedTaskExecutor executor = new SingleThreadNamedTaskExecutor(
57 executor);
/packages/providers/CalendarProvider/src/com/android/providers/calendar/
H A DCalendarReceiver.java39 private final ExecutorService executor = Executors.newCachedThreadPool(); field in class:CalendarReceiver
54 executor.submit(new Runnable() {
/packages/apps/Camera2/src/com/android/camera/one/v2/sharedimagereader/ringbuffer/
H A DAvailableTicketCounter.java54 public SafeCloseable addCallback(final Runnable callback, final Executor executor) { argument
57 callbackLifetime.add(input.addCallback(callback, executor));
/packages/apps/Camera2/src/com/android/camera/one/v2/core/
H A DObservableFrameServer.java117 public SafeCloseable addCallback(Runnable callback, Executor executor) { argument
118 return mAvailability.addCallback(callback, executor);

Completed in 4152 milliseconds

12