| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| Executor.java | 42 * use, scheduling, etc. An {@code Executor} is normally used
48 * Executor executor = anExecutor();
49 * executor.execute(new RunnableTask1());
50 * executor.execute(new RunnableTask2());
53 * However, the {@code Executor} interface does not strictly require
54 * that execution be asynchronous. In the simplest case, an executor
58 * class DirectExecutor implements Executor {
65 * caller's thread. The executor below spawns a new thread for each
69 * class ThreadPerTaskExecutor implements Executor {
[all...] |
| /packages/apps/Dialer/java/com/android/incallui/async/ |
| PausableExecutor.java | 19 import java.util.concurrent.Executor;
22 * Executor that can be used to easily synchronize testing and production code. Production code
27 public interface PausableExecutor extends Executor {
30 * Method called from asynchronous production code to inform this executor that it has reached a
38 * Method called from the test code to inform this executor that the state of the production
45 * Method called from the test code to inform this executor that the tests are finished with all
|
| /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;
|
| /frameworks/support/paging/runtime/src/main/java/android/support/v7/recyclerview/extensions/ |
| ListAdapterConfig.java | 19 import android.arch.core.executor.AppToolkitTaskExecutor;
21 import java.util.concurrent.Executor;
33 private final Executor mMainThreadExecutor;
34 private final Executor mBackgroundThreadExecutor;
37 private ListAdapterConfig(Executor mainThreadExecutor, Executor backgroundThreadExecutor,
44 public Executor getMainThreadExecutor() {
48 public Executor getBackgroundThreadExecutor() {
64 private Executor mMainThreadExecutor;
65 private Executor mBackgroundThreadExecutor
[all...] |
| /packages/apps/TV/src/com/android/tv/util/ |
| NetworkTrafficTags.java | 22 import java.util.concurrent.Executor;
33 * An executor which simply wraps a provided delegate executor, but calls {@link
36 public static class TrafficStatsTaggingExecutor implements Executor {
37 private final Executor delegateExecutor;
40 public TrafficStatsTaggingExecutor(Executor delegateExecutor, int tag) {
|
| /external/volley/src/test/java/com/android/volley/utils/ |
| ImmediateResponseDelivery.java | 21 import java.util.concurrent.Executor;
30 super(new Executor() {
|
| /packages/apps/Camera2/src/com/android/camera/async/ |
| HandlerExecutor.java | 19 import java.util.concurrent.Executor;
26 * An {@link Executor} which posts to a {@link Handler}.
29 public class HandlerExecutor implements Executor {
|
| ExecutorCallback.java | 21 import java.util.concurrent.Executor;
28 * which runs it on an executor.
34 private final Executor mExecutor;
38 * @param executor The executor on which to invoke the callback.
40 public ExecutorCallback(Callback<T> callback, Executor executor) {
42 mExecutor = executor;
|
| ForwardingObservable.java | 21 import java.util.concurrent.Executor;
38 public SafeCloseable addCallback(Runnable callback, Executor executor) {
39 return mDelegate.addCallback(callback, executor);
|
| Observable.java | 21 import java.util.concurrent.Executor;
42 * @param executor The executor on which the callback will be invoked.
47 public SafeCloseable addCallback(Runnable callback, Executor executor);
|
| /packages/apps/Camera2/src/com/android/camera/processing/imagebackend/ |
| ImageTaskManager.java | 20 import java.util.concurrent.Executor;
58 * @param executor the executor on which the image close is run. if null,
62 public void releaseSemaphoreReference(final ImageToProcess img, Executor executor);
|
| /frameworks/support/app-toolkit/runtime/src/main/java/android/arch/core/executor/ |
| AppToolkitTaskExecutor.java | 17 package android.arch.core.executor;
23 import java.util.concurrent.Executor;
42 private static final Executor sMainThreadExecutor = new Executor() {
50 private static final Executor sIOThreadExecutor = new Executor() {
63 * Returns an instance of the task executor.
82 * If you have a common executor, you can set it as the delegate and App Toolkit components will
87 * @param taskExecutor The task executor to handle task requests.
104 public static Executor getMainThreadExecutor()
[all...] |
| /packages/apps/Gallery2/gallerycommon/src/com/android/gallery3d/common/ |
| AsyncTaskUtil.java | 24 import java.util.concurrent.Executor;
31 private static Executor sExecutor;
35 sExecutor = (Executor) AsyncTask.class.getField("THREAD_POOL_EXECUTOR")
38 "executeOnExecutor", Executor.class, Object[].class);
|
| /art/tools/dexfuzz/src/dexfuzz/listeners/ |
| FinalStatusListener.java | 22 import dexfuzz.executors.Executor;
35 public void handleDivergences(Map<String, List<Executor>> outputMap) {
|
| BaseListener.java | 20 import dexfuzz.executors.Executor;
44 public void handleTimeouts(List<Executor> timedOut, List<Executor> didNotTimeOut) { }
46 public void handleDivergences(Map<String, List<Executor>> outputMap) { }
54 public void handleSuccess(Map<String, List<Executor>> outputMap) { }
56 public void handleDumpOutput(String outputLine, Executor executor) { }
|
| UpdatingConsoleListener.java | 20 import dexfuzz.executors.Executor;
75 public void handleTimeouts(List<Executor> timedOut, List<Executor> didNotTimeOut) {
80 public void handleDivergences(Map<String, List<Executor>> outputMap) {
95 public void handleSuccess(Map<String, List<Executor>> outputMap) {
|
| ConsoleLoggerListener.java | 20 import dexfuzz.executors.Executor;
82 public void handleTimeouts(List<Executor> timedOut, List<Executor> didNotTimeOut) {
87 public void handleDivergences(Map<String, List<Executor>> outputMap) {
90 for (List<Executor> executors : outputMap.values()) {
92 for (Executor executor : executors) {
93 logToConsole(" " + executor.getName());
120 public void handleSuccess(Map<String, List<Executor>> outputMap) {
125 public void handleDumpOutput(String outputLine, Executor executor)
[all...] |
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| ListenableFuture.java | 19 import java.util.concurrent.Executor;
27 * associated executor, and it is invoked using this executor once the future's
58 * }, executor);}</pre>
88 * Registers a listener to be {@linkplain Executor#execute(Runnable) run} on
89 * the given executor. The listener will run when the {@code Future}'s
97 * <p>Exceptions thrown by a listener will be propagated up to the executor.
98 * Any exception thrown during {@code Executor.execute} (e.g., a {@code
129 * @param executor the executor to run the listener i
[all...] |
| JdkFutureAdapters.java | 24 import java.util.concurrent.Executor;
72 * ListenableFuture#addListener} by submitting a task to the given executor at
74 * executor promptly, or else the returned {@code ListenableFuture} may fail
91 Future<V> future, Executor executor) {
92 checkNotNull(executor);
96 return new ListenableFutureAdapter<V>(future, executor);
117 private static final Executor defaultAdapterExecutor =
120 private final Executor adapterExecutor;
136 ListenableFutureAdapter(Future<V> delegate, Executor adapterExecutor)
[all...] |
| ForwardingListenableFuture.java | 21 import java.util.concurrent.Executor;
46 public void addListener(Runnable listener, Executor exec) {
|
| /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/dagger2/compiler/src/it/producers-functional-tests/src/main/java/producerstest/builder/ |
| TestComponentWithBuilder.java | 20 import java.util.concurrent.Executor;
34 Builder executor(Executor executor); method in interface:TestComponentWithBuilder.Builder
|
| /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() {
|
| /frameworks/support/paging/common/src/test/java/android/arch/paging/ |
| TestExecutor.java | 23 import java.util.concurrent.Executor;
25 public class TestExecutor implements Executor {
|
| /frameworks/support/paging/runtime/src/androidTest/java/android/arch/paging/ |
| TestExecutor.java | 23 import java.util.concurrent.Executor;
25 public class TestExecutor implements Executor {
|
