/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(
|