/packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
H A D | MockNamedTaskExecutorFactory.java | 30 * 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 D | PerNameExecutor.java | 23 * 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 D | BatchingNamedTaskExecutor.java | 42 * @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 D | RunnableCameraCommand.java | 27 public RunnableCameraCommand(CameraCommandExecutor executor, CameraCommand command) { argument 28 mExecutor = executor;
|
H A D | ResettingRunnableCameraCommand.java | 44 public ResettingRunnableCameraCommand(CameraCommandExecutor executor, CameraCommand command) { argument 45 mExecutor = executor;
|
/packages/inputmethods/LatinIME/native/dicttoolkit/ |
H A D | dict_toolkit_main.cpp | 37 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 D | ExecutorUtilsTests.java | 38 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 D | ExecutorCallback.java | 28 * 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 D | ForwardingObservable.java | 38 public SafeCloseable addCallback(Runnable callback, Executor executor) { argument 39 return mDelegate.addCallback(callback, executor);
|
H A D | ConcurrentState.java | 37 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 D | ResettingDelayedExecutor.java | 25 * 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 D | Observables.java | 63 public SafeCloseable addCallback(Runnable callback, Executor executor) { 64 return input.addCallback(callback, executor); 102 public SafeCloseable addCallback(Runnable callback, Executor executor) {
|
H A D | Observable.java | 42 * @param executor The executor on which the callback will be invoked. 47 public SafeCloseable addCallback(Runnable callback, Executor executor); argument
|
H A D | ObservableCombiner.java | 84 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 D | ImageTaskManager.java | 58 * @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 D | TaskPreviewChainedJpeg.java | 39 * @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 D | ImageBackend.java | 245 * @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 D | TaskChainedCompressImageToJpeg.java | 40 TaskChainedCompressImageToJpeg(ImageToProcess image, Executor executor, argument 42 super(image, executor, imageTaskManager, ProcessingPriority.SLOW, captureSession);
|
/packages/apps/Camera2/src/com/android/camera/settings/ |
H A D | SettingObserver.java | 38 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 D | AsyncTaskExecutors.java | 89 public SimpleAsyncTaskExecutor(Executor executor) { argument 90 mExecutor = executor;
|
/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/ |
H A D | QueryTask.java | 79 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 D | PackageIconLoaderTest.java | 54 NamedTaskExecutor executor = new SingleThreadNamedTaskExecutor( 57 executor);
|
/packages/providers/CalendarProvider/src/com/android/providers/calendar/ |
H A D | CalendarReceiver.java | 39 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 D | AvailableTicketCounter.java | 54 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 D | ObservableFrameServer.java | 117 public SafeCloseable addCallback(Runnable callback, Executor executor) { argument 118 return mAvailability.addCallback(callback, executor);
|