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

123

/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/apps/DocumentsUI/tests/common/com/android/documentsui/testing/
H A DTestImmediateExecutor.java33 final TestImmediateExecutor executor = new TestImmediateExecutor();
35 return 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/apps/DocumentsUI/src/com/android/documentsui/
H A DProviderExecutor.java36 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 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
/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/Settings/tests/robotests/src/com/android/settings/testutils/shadow/
H A DShadowRunnableAsyncTask.java35 public AsyncTask<Params, Progress, Result> executeOnExecutor(Executor executor, argument
/packages/apps/Contacts/src/com/android/contacts/util/concurrent/
H A DFuturesUtil.java39 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 DAsyncTaskExecutors.java81 public SimpleAsyncTaskExecutor(Executor executor) { argument
82 mExecutor = executor;
/packages/apps/Launcher3/tests/src/com/android/launcher3/util/
H A DCondition.java19 final MainThreadExecutor executor = new MainThreadExecutor();
26 executor.execute(new Runnable() {
/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() {

Completed in 2054 milliseconds

123