HomeSort by relevance Sort by last modified time
    Searched defs:executor (Results 76 - 100 of 764) sorted by null

1 2 34 5 6 7 8 91011>>

  /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/
ShadowAsyncTask.java 7 import java.util.concurrent.Executor;
100 public AsyncTask<Params, Progress, Result> executeOnExecutor(Executor executor, Params... params) {
105 executor.execute(new Runnable() {
  /frameworks/base/core/tests/coretests/src/android/net/
NetworkRecommendationProviderTest.java 22 import java.util.concurrent.Executor;
41 Executor executor = Executors.newSingleThreadExecutor(); local
43 mRecProvider = new NetworkRecProvider(mContext, executor, mScoreRequestLatch);
94 NetworkRecProvider(Context context, Executor executor, CountDownLatch networkRequestLatch) {
95 super(context, executor);
  /frameworks/support/app-toolkit/core-testing/src/main/java/androidx/arch/core/executor/testing/
CountingTaskExecutorRule.java 17 package androidx.arch.core.executor.testing;
21 import androidx.arch.core.executor.ArchTaskExecutor;
22 import androidx.arch.core.executor.DefaultTaskExecutor;
31 * A JUnit Test Rule that swaps the background executor used by the Architecture Components with a
  /frameworks/support/media/src/androidTest/java/androidx/media/
MockMediaSessionService2.java 27 import java.util.concurrent.Executor;
54 final Executor executor = new Executor() { local
67 .setSessionCallback(executor, sessionCallback)
MockPlayer.java 24 import java.util.concurrent.Executor;
46 public ArrayMap<PlayerEventCallback, Executor> mCallbacks = new ArrayMap<>();
136 public void registerPlayerEventCallback(@NonNull Executor executor,
138 if (callback == null || executor == null) {
139 throw new IllegalArgumentException("callback=" + callback + " executor=" + executor);
141 mCallbacks.put(callback, executor);
153 final Executor executor = mCallbacks.valueAt(i) local
166 final Executor executor = mCallbacks.valueAt(i); local
179 final Executor executor = mCallbacks.valueAt(i); local
193 final Executor executor = mCallbacks.valueAt(i); local
206 final Executor executor = mCallbacks.valueAt(i); local
219 final Executor executor = mCallbacks.valueAt(i); local
232 final Executor executor = mCallbacks.valueAt(i); local
    [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;
121 ExecutorService executor = Executors.newCachedThreadPool(threadFactory); local
122 return new ThreadPool(executor, false, initialSize);
129 ExecutorService executor = Executors.newFixedThreadPool(nThreads, factory); local
130 return new ThreadPool(executor, true, nThreads)
    [all...]
  /packages/apps/DocumentsUI/src/com/android/documentsui/inspector/
DebugView.java 38 import java.util.concurrent.Executor;
49 private Lookup<String, Executor> mExecutors = new DummyLookup<>();
65 void init(Lookup<String, Executor> executors) {
96 Executor executor = mExecutors.lookup(info.derivedUri.getAuthority()); local
97 if (executor != null) {
109 }.executeOnExecutor(executor, (Void[]) null);
  /test/suite_harness/common/host-side/tradefed/src/com/android/compatibility/common/tradefed/testtype/
BusinessLogicHostTestBase.java 68 BusinessLogicExecutor executor = new BusinessLogicHostExecutor(getDevice(), local
70 mBusinessLogic.applyLogicFor(testName, executor);
  /prebuilts/tools/common/m2/repository/io/netty/netty-resolver/4.1.0.CR3/
netty-resolver-4.1.0.CR3.jar 
  /prebuilts/tools/common/m2/repository/io/netty/netty-resolver/4.1.3.Final/
netty-resolver-4.1.3.Final.jar 
  /cts/libs/vogar-expect/src/vogar/commands/
Command.java 188 ExecutorService executor = Threads.fixedThreadsExecutor("command", 1); local
189 Future<List<String>> result = executor.submit(new Callable<List<String>>() {
195 executor.shutdown();
  /cts/tests/tests/media/src/android/media/cts/
MockPlayer.java 27 import java.util.concurrent.Executor;
45 public ArrayMap<PlayerEventCallback, Executor> mCallbacks = new ArrayMap<>();
134 public void registerPlayerEventCallback(@NonNull Executor executor,
136 mCallbacks.put(callback, executor);
148 final Executor executor = mCallbacks.valueAt(i); local
149 executor.execute(() -> callback.onPlayerStateChanged(this, state));
156 final Executor executor = mCallbacks.valueAt(i) local
164 final Executor executor = mCallbacks.valueAt(i); local
172 final Executor executor = mCallbacks.valueAt(i); local
180 final Executor executor = mCallbacks.valueAt(i); local
    [all...]
  /external/conscrypt/benchmark-base/src/main/java/org/conscrypt/
ServerEndpoint.java 71 private ExecutorService executor; field in class:ServerEndpoint
95 executor = Executors.newSingleThreadExecutor();
96 return executor.submit(new AcceptTask());
114 if (executor != null) {
115 executor.shutdown();
116 executor.awaitTermination(5, TimeUnit.SECONDS);
117 executor = null;
147 processFuture = executor.submit(new ProcessTask());
  /external/conscrypt/openjdk/src/test/java/org/conscrypt/
RenegotiationTest.java 140 private ExecutorService executor; field in class:RenegotiationTest.Client
157 executor = Executors.newSingleThreadExecutor();
170 if (executor != null) {
171 executor.shutdown();
172 executor.awaitTermination(5, TimeUnit.SECONDS);
173 executor = null;
183 return executor.submit(new Runnable() {
230 private ExecutorService executor;
250 executor = Executors.newSingleThreadExecutor();
251 return executor.submit(new AcceptTask())
    [all...]
  /external/guice/extensions/servlet/test/com/google/inject/servlet/
ContinuingRequestIntegrationTest.java 101 private ExecutorService executor; field in class:ContinuingRequestIntegrationTest
110 executor = Executors.newSingleThreadExecutor();
116 bind(ExecutorService.class).toInstance(executor);
143 executor.shutdown();
144 executor.awaitTermination(10, TimeUnit.SECONDS);
152 executor = sameThreadExecutor;
157 bind(ExecutorService.class).toInstance(executor);
185 executor.shutdown();
186 executor.awaitTermination(10, TimeUnit.SECONDS);
ScopeRequestIntegrationTest.java 56 ExecutorService executor = Executors.newSingleThreadExecutor(); local
69 executor.submit(ServletScopes.scopeRequest(offRequestCallable,
80 executor.submit(ServletScopes.scopeRequest(offRequestCallable,
88 executor.shutdown();
89 executor.awaitTermination(2, TimeUnit.SECONDS);
  /frameworks/av/packages/MediaComponents/src/com/android/media/
MediaPlaylistAgentImpl.java 34 import java.util.concurrent.Executor;
43 private final ArrayMap<PlaylistEventCallback, Executor> mCallbacks = new ArrayMap<>();
51 @NonNull @CallbackExecutor Executor executor, @NonNull PlaylistEventCallback callback) {
52 if (executor == null) {
53 throw new IllegalArgumentException("executor shouldn't be null");
64 mCallbacks.put(callback, executor);
81 ArrayMap<PlaylistEventCallback, Executor> callbacks = getCallbacks();
86 final Executor executor = callbacks.valueAt(i) local
97 final Executor executor = callbacks.valueAt(i); local
108 final Executor executor = callbacks.valueAt(i); local
119 final Executor executor = callbacks.valueAt(i); local
    [all...]
  /frameworks/base/core/java/android/hardware/biometrics/
BiometricPrompt.java 33 import java.util.concurrent.Executor;
88 Executor executor; field in class:BiometricPrompt.ButtonInfo
90 ButtonInfo(Executor ex, DialogInterface.OnClickListener l) {
91 executor = ex;
152 @NonNull @CallbackExecutor Executor executor,
157 if (executor == null) {
158 throw new IllegalArgumentException("Executor must not be null");
164 mPositiveButtonInfo = new ButtonInfo(executor, listener)
    [all...]
  /frameworks/support/media/src/main/java/androidx/media/
MediaPlaylistAgent.java 33 import java.util.concurrent.Executor;
106 private final SimpleArrayMap<PlaylistEventCallback, Executor> mCallbacks =
113 * @param executor a callback Executor
115 * @throws IllegalArgumentException if executor or callback is {@code null}.
118 @NonNull /*@CallbackExecutor*/ Executor executor,
120 if (executor == null) {
121 throw new IllegalArgumentException("executor shouldn't be null");
132 mCallbacks.put(callback, executor);
164 final Executor executor = callbacks.valueAt(i); local
185 final Executor executor = callbacks.valueAt(i); local
206 final Executor executor = callbacks.valueAt(i); local
227 final Executor executor = callbacks.valueAt(i); local
    [all...]
  /frameworks/support/media/version-compat-tests/current/client/src/androidTest/java/androidx/media/test/client/
MockPlayer.java 27 import java.util.concurrent.Executor;
49 public ArrayMap<PlayerEventCallback, Executor> mCallbacks = new ArrayMap<>();
139 public void registerPlayerEventCallback(@NonNull Executor executor,
141 if (callback == null || executor == null) {
142 throw new IllegalArgumentException("callback=" + callback + " executor=" + executor);
144 mCallbacks.put(callback, executor);
156 final Executor executor = mCallbacks.valueAt(i) local
169 final Executor executor = mCallbacks.valueAt(i); local
182 final Executor executor = mCallbacks.valueAt(i); local
196 final Executor executor = mCallbacks.valueAt(i); local
209 final Executor executor = mCallbacks.valueAt(i); local
222 final Executor executor = mCallbacks.valueAt(i); local
235 final Executor executor = mCallbacks.valueAt(i); local
    [all...]
  /frameworks/support/media/version-compat-tests/current/service/src/androidTest/java/androidx/media/test/service/
MockPlayer.java 27 import java.util.concurrent.Executor;
49 public ArrayMap<PlayerEventCallback, Executor> mCallbacks = new ArrayMap<>();
139 public void registerPlayerEventCallback(@NonNull Executor executor,
141 if (callback == null || executor == null) {
142 throw new IllegalArgumentException("callback=" + callback + " executor=" + executor);
144 mCallbacks.put(callback, executor);
156 final Executor executor = mCallbacks.valueAt(i) local
169 final Executor executor = mCallbacks.valueAt(i); local
182 final Executor executor = mCallbacks.valueAt(i); local
196 final Executor executor = mCallbacks.valueAt(i); local
209 final Executor executor = mCallbacks.valueAt(i); local
222 final Executor executor = mCallbacks.valueAt(i); local
235 final Executor executor = mCallbacks.valueAt(i); local
    [all...]
  /frameworks/support/slices/view/src/androidTest/java/androidx/slice/render/
SliceRenderer.java 139 ExecutorService executor = Executors.newFixedThreadPool(5); local
143 executor.execute(new Runnable() {
151 executor.execute(new Runnable() {
160 executor.execute(new Runnable() {
  /libcore/luni/src/test/java/libcore/java/util/zip/
DeflaterOutputStreamTest.java 76 ExecutorService executor = Executors.newSingleThreadExecutor(); local
80 executor.submit(new Callable<Void>() {
97 executor.shutdown();
  /libcore/luni/src/test/java/libcore/libcore/net/
NetworkSecurityPolicyTest.java 241 private final ExecutorService executor; field in class:NetworkSecurityPolicyTest.CapturingServerSocket
279 executor = Executors.newSingleThreadExecutor();
280 mFirstChunkReceivedFuture = executor.submit(callable);
294 executor.shutdown();
  /packages/apps/Dialer/java/com/android/voicemail/impl/fetch/
FetchVoicemailReceiver.java 44 import java.util.concurrent.Executor;
200 Executor executor = Executors.newCachedThreadPool(); local
201 executor.execute(

Completed in 658 milliseconds

1 2 34 5 6 7 8 91011>>