/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/apps/DocumentsUI/tests/common/com/android/documentsui/testing/ |
H A D | TestImmediateExecutor.java | 33 final TestImmediateExecutor executor = new TestImmediateExecutor(); 35 return 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/apps/DocumentsUI/src/com/android/documentsui/ |
H A D | ProviderExecutor.java | 36 ProviderExecutor executor = sExecutors.get(authority); 37 if (executor == null) { 38 executor = new ProviderExecutor(); 39 executor.setName("ProviderExecutor: " + authority); 40 executor.start(); 41 sExecutors.put(authority, executor); 43 return executor;
|
/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
|
/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/Settings/tests/robotests/src/com/android/settings/testutils/shadow/ |
H A D | ShadowRunnableAsyncTask.java | 35 public AsyncTask<Params, Progress, Result> executeOnExecutor(Executor executor, argument
|
/packages/apps/Contacts/src/com/android/contacts/util/concurrent/ |
H A D | FuturesUtil.java | 39 TimeUnit unit, ScheduledExecutorService executor) { 41 executor.schedule(new Runnable() { 38 withTimeout(final ListenableFuture<V> future, long time, TimeUnit unit, ScheduledExecutorService executor) argument
|
/packages/apps/Dialer/java/com/android/dialer/common/concurrent/ |
H A D | AsyncTaskExecutors.java | 81 public SimpleAsyncTaskExecutor(Executor executor) { argument 82 mExecutor = executor;
|
/packages/apps/Launcher3/tests/src/com/android/launcher3/util/ |
H A D | Condition.java | 19 final MainThreadExecutor executor = new MainThreadExecutor(); 26 executor.execute(new Runnable() {
|
/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() {
|