| /packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
| MockNamedTaskExecutorFactory.java | 30 * Runs one task in each executor.
33 for (MockNamedTaskExecutor executor : mExecutors) {
34 executor.runNext();
39 MockNamedTaskExecutor executor = new MockNamedTaskExecutor(); local
40 mExecutors.add(executor);
41 return executor;
|
| /external/glide/library/src/main/java/com/bumptech/glide/load/engine/executor/ |
| Prioritized.java | 1 package com.bumptech.glide.load.engine.executor;
|
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| 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); local
57 if (executor == null) {
58 executor = mExecutorFactory.create();
59 mExecutors.put(name, executor);
61 executor.execute(task)
[all...] |
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| RejectedExecutionHandler.java | 51 * shutdown of the Executor.
58 * @param executor the executor attempting to execute this task
61 void rejectedExecution(Runnable r, ThreadPoolExecutor executor);
|
| ExecutorCompletionService.java | 39 * A {@link CompletionService} that uses a supplied {@link Executor}
56 * void solve(Executor e,
76 * void solve(Executor e,
107 private final Executor executor; field in class:ExecutorCompletionService
142 * executor for base task execution and a
145 * @param executor the executor to use
146 * @throws NullPointerException if executor is {@code null}
148 public ExecutorCompletionService(Executor executor)
[all...] |
| /external/guava/guava/src/com/google/common/eventbus/ |
| AsyncEventBus.java | 24 import java.util.concurrent.Executor;
27 * An {@link EventBus} that takes the Executor of your choice and uses it to
35 private final Executor executor; field in class:AsyncEventBus
42 * Creates a new AsyncEventBus that will use {@code executor} to dispatch
46 * @param executor Executor to use to dispatch events. It is the caller's
47 * responsibility to shut down the executor after the last event has
50 public AsyncEventBus(String identifier, Executor executor) {
[all...] |
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| ExecutionList.java | 22 import java.util.concurrent.Executor;
30 * <p>A list of listeners, each with an associated {@code Executor}, that
37 * <p>Exceptions thrown by a listener will be propagated up to the executor.
38 * Any exception thrown during {@code Executor.execute} (e.g., a {@code
52 * The runnable, executor pairs to execute. This acts as a stack threaded through the
64 * Adds the {@code Runnable} and accompanying {@code Executor} to the list of
81 public void add(Runnable runnable, Executor executor) {
83 // Executor states that it throws NPE on null listener, so we propagate
86 Preconditions.checkNotNull(executor, "Executor was null.")
168 final Executor executor; field in class:ExecutionList.RunnableExecutorPair
[all...] |
| SerializingExecutor.java | 23 import java.util.concurrent.Executor;
30 * Executor ensuring that all Runnables submitted are executed in order,
31 * using the provided Executor, and serially such that no two will ever
34 * TODO(user): The tasks are given to the underlying executor as a single
35 * task, which means the semantics of the executor may be changed, e.g. the
36 * executor may have an afterExecute method that runs after every task
46 final class SerializingExecutor implements Executor {
50 /** Underlying executor that all submitted Runnable objects are run on. */
51 private final Executor executor; field in class:SerializingExecutor
[all...] |
| AbstractScheduledService.java | 27 import java.util.concurrent.Executor;
45 * <p>This class uses the {@link ScheduledExecutorService} returned from {@link #executor} to run
125 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
127 return executor.scheduleWithFixedDelay(task, initialDelay, delay, unit);
144 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
146 return executor.scheduleAtFixedRate(task, initialDelay, period, unit);
151 /** Schedules the task to run on the provided executor on behalf of the service. */
152 abstract Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
191 executorService = MoreExecutors.renamingDecorator(executor(), new Supplier<String>() {
274 * executor will not be {@linkplain ScheduledExecutorService#shutdown shutdown} when this
[all...] |
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| ThreadPool.java | 43 private final ExecutorService executor; field in class:ThreadPool
52 private ThreadPool(ExecutorService executor,
56 this.executor = executor;
61 ExecutorService executor() { method in class:ThreadPool
62 return executor;
113 ExecutorService executor = Executors.newCachedThreadPool(threadFactory); local
114 return new ThreadPool(executor, false, initialSize);
121 ExecutorService executor = Executors.newFixedThreadPool(nThreads, factory); local
122 return new ThreadPool(executor, true, nThreads)
[all...] |
| /cts/common/util/src/com/android/compatibility/common/util/ |
| BusinessLogic.java | 49 * @param executor a {@link BusinessLogicExecutor}
51 public void applyLogicFor(String testName, BusinessLogicExecutor executor) {
58 if (rule.invokeConditions(executor)) {
59 rule.invokeActions(executor);
84 public boolean invokeConditions(BusinessLogicExecutor executor) {
86 if (!condition.invoke(executor)) {
96 public void invokeActions(BusinessLogicExecutor executor) {
98 action.invoke(executor);
124 * Invoke this Business Logic condition with an executor.
126 public boolean invoke(BusinessLogicExecutor executor) {
[all...] |
| /packages/apps/Camera2/src/com/android/camera/one/v2/commands/ |
| RunnableCameraCommand.java | 27 public RunnableCameraCommand(CameraCommandExecutor executor, CameraCommand command) {
28 mExecutor = executor;
|
| /packages/apps/DocumentsUI/tests/common/com/android/documentsui/testing/ |
| TestImmediateExecutor.java | 21 import java.util.concurrent.Executor;
24 * An {@link Executor} that executes command in place.
26 public class TestImmediateExecutor implements Executor {
32 public static Lookup<String, Executor> createLookup() {
33 final TestImmediateExecutor executor = new TestImmediateExecutor(); local
35 return executor;
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| MoreExecutorsDirectExecutorBenchmark.java | 31 import java.util.concurrent.Executor;
42 @Override Executor executor() { method
46 EXECUTOR {
47 @Override Executor executor() { method
51 abstract Executor executor(); method in class:MoreExecutorsDirectExecutorBenchmark.Impl
55 Executor executor; field in class:MoreExecutorsDirectExecutorBenchmark
96 final Executor executor = this.executor; local
105 final Executor executor = this.executor; local
[all...] |
| ExecutionListBenchmark.java | 33 import java.util.concurrent.Executor;
53 void add(Runnable runnable, Executor executor);
64 @Override public void add(Runnable runnable, Executor executor) {
65 list.add(runnable, executor);
82 @Override public void add(Runnable runnable, Executor executor) {
83 list.add(runnable, executor);
100 @Override public void add(Runnable runnable, Executor executor)
[all...] |
| /external/r8/src/main/java/com/android/tools/r8/ |
| IncrementalDexingBenchmark.java | 14 public static void compile(ExecutorService executor) throws IOException, CompilationException {
21 executor);
29 ExecutorService executor = ThreadUtils.getExecutorService(threads); local
33 compile(executor);
38 executor.shutdown();
|
| /external/webrtc/webrtc/examples/androidtests/src/org/appspot/apprtc/test/ |
| LooperExecutorTest.java | 38 LooperExecutor executor = new LooperExecutor(); local
40 // Try to execute a counter increment task before starting an executor.
41 executor.execute(counterIncRunnable);
43 // Start the executor and run expected amount of counter increment task.
44 executor.requestStart();
46 executor.execute(counterIncRunnable);
48 executor.execute(new Runnable() {
54 executor.requestStop();
56 // Try to execute a task after stopping the executor.
57 executor.execute(counterIncRunnable)
[all...] |
| /external/guava/guava/src/com/google/common/cache/ |
| RemovalListeners.java | 23 import java.util.concurrent.Executor;
38 * notifications using {@code executor}.
41 * @param executor the executor with which removal notifications are
45 final RemovalListener<K, V> listener, final Executor executor) {
47 checkNotNull(executor);
51 executor.execute(new Runnable() {
|
| /libcore/ojluni/src/main/java/java/nio/channels/ |
| AsynchronousChannelGroup.java | 193 * <p> The {@code executor} parameter is an {@code ExecutorService} that
204 * <p> The executor is intended to be used exclusively by the resulting
206 * orderly {@link ExecutorService#shutdown shutdown} of the executor
207 * service. Shutting down the executor service by other means results in
215 * @param executor
228 public static AsynchronousChannelGroup withCachedThreadPool(ExecutorService executor,
233 .openAsynchronousChannelGroup(executor, initialSize);
239 * <p> The {@code executor} parameter is an {@code ExecutorService} that
243 * <p> Care should be taken when configuring the executor service. It
249 * <p> The executor is intended to be used exclusively by the resultin
[all...] |
| /packages/inputmethods/LatinIME/native/dicttoolkit/ |
| dict_toolkit_main.cpp | 37 const auto executor = CommandUtils::getCommandExecutor(commandType); local
38 return executor(argc - 1, argv + 1);
|
| /external/guice/extensions/service/src/com/google/inject/service/ |
| AsyncService.java | 37 private final ExecutorService executor; field in class:AsyncService
41 public AsyncService(ExecutorService executor) {
42 this.executor = executor;
54 return executor.submit(new Callable<State>() {
79 return executor.submit(new Callable<State>() {
|
| /frameworks/base/tools/aapt2/xml/ |
| XmlActionExecutor_test.cpp | 27 XmlActionExecutor executor; local
28 XmlNodeAction& manifest_action = executor["manifest"];
47 ASSERT_TRUE(executor.Execute(XmlActionExecutorPolicy::kNone, &diag, doc.get()));
56 XmlActionExecutor executor; local
57 executor["manifest"]["application"];
62 ASSERT_FALSE(executor.Execute(XmlActionExecutorPolicy::kWhitelist, &diag, doc.get()));
|
| /packages/apps/DocumentsUI/src/com/android/documentsui/ |
| ProviderExecutor.java | 26 import java.util.concurrent.Executor;
29 public class ProviderExecutor extends Thread implements Executor {
36 ProviderExecutor executor = sExecutors.get(authority); local
37 if (executor == null) {
38 executor = new ProviderExecutor();
39 executor.setName("ProviderExecutor: " + authority);
40 executor.start();
41 sExecutors.put(authority, executor);
43 return executor;
84 private Executor mNonPreemptingExecutor = new Executor()
[all...] |
| /external/mockito/src/test/java/org/mockitousage/verification/ |
| DelayedExecution.java | 20 private final ScheduledExecutorService executor; field in class:DelayedExecution
23 this.executor = newScheduledThreadPool(CORE_POOL_SIZE, maxPrioThreadFactory());
29 executor.submit(delayedExecution(r, deadline));
33 executor.shutdownNow();
35 if (!executor.awaitTermination(5, SECONDS)) {
|
| /frameworks/base/core/java/android/net/ |
| NetworkRecommendationProvider.java | 30 import java.util.concurrent.Executor;
59 * @param executor used to execute the incoming requests. Cannot be {@code null}.
61 public NetworkRecommendationProvider(Context context, Executor executor) {
63 Preconditions.checkNotNull(executor);
64 mService = new ServiceWrapper(context, executor);
89 private final Executor mExecutor;
92 ServiceWrapper(Context context, Executor executor) {
94 mExecutor = executor;
[all...] |
