| /external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/ |
| MultibindingTest.java | 35 DaggerMultibindingComponent.builder().executor(MoreExecutors.directExecutor()).build();
44 DaggerMultibindingComponent.builder().executor(MoreExecutors.directExecutor()).build();
58 DaggerMultibindingComponent.builder().executor(MoreExecutors.directExecutor()).build();
|
| SimpleTest.java | 30 .executor(MoreExecutors.directExecutor())
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| 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...] |
| /external/tensorflow/tensorflow/compiler/xla/service/interpreter/ |
| platform.cc | 20 #include "tensorflow/compiler/xla/service/interpreter/executor.h"
75 auto executor = port::MakeUnique<StreamExecutor>( local
77 auto init_status = executor->Init(config.ordinal, config.device_options);
86 return std::move(executor);
91 LOG(FATAL) << "not yet implemented: register executor trace listener";
95 LOG(FATAL) << "not yet implemented: unregister executor trace listener";
|
| executable.cc | 29 #include "tensorflow/compiler/xla/service/interpreter/executor.h"
55 se::StreamExecutor* executor = stream->parent(); local
56 const se::Platform* platform = executor->platform();
82 transfer_manager->TransferLiteralFromDevice(executor, *arguments[p]));
98 executor, *result_literal, *result));
|
| /external/tensorflow/tensorflow/stream_executor/host/ |
| host_platform.cc | 72 auto executor = port::MakeUnique<StreamExecutor>( local
74 auto init_status = executor->Init(config.ordinal, config.device_options);
83 return std::move(executor);
|
| /libcore/luni/src/test/java/tests/security/ |
| SecureRandomTest.java | 79 ExecutorService executor = Executors.newFixedThreadPool(threads); local
80 ExecutorCompletionService ecs = new ExecutorCompletionService(executor);
91 executor.shutdown();
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| SimpleAsynchronousFileChannelImpl.java | 47 ThreadPool.createDefault().executor();
60 ExecutorService executor)
62 super(fdObj, reading, writing, executor);
70 // Executor is either default or based on pool parameters
71 ExecutorService executor = (pool == null) ? local
72 DefaultExecutorHolder.defaultExecutor : pool.executor();
73 return new SimpleAsynchronousFileChannelImpl(fdo, reading, writing, executor);
190 Invoker.invokeIndirectly(handler, attachment, null, exc, executor);
231 executor.execute(task);
305 Invoker.invokeIndirectly(handler, attachment, 0, exc, executor);
[all...] |
| /packages/apps/Camera2/src/com/android/camera/async/ |
| Observables.java | 25 import java.util.concurrent.Executor;
63 public SafeCloseable addCallback(Runnable callback, Executor executor) {
64 return input.addCallback(callback, executor);
102 public SafeCloseable addCallback(Runnable callback, Executor 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);
|
| /art/tools/dexfuzz/src/dexfuzz/listeners/ |
| 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...] |
| LogFileListener.java | 21 import dexfuzz.executors.Executor;
113 public void handleTimeouts(List<Executor> timedOut, List<Executor> didNotTimeOut) {
116 for (Executor executor : timedOut) {
117 write(" " + executor.getName());
121 for (Executor executor : didNotTimeOut) {
122 write(" " + executor.getName());
129 public void handleDivergences(Map<String, List<Executor>> outputMap)
[all...] |
| /dalvik/dx/tests/127-merge-stress/com/android/dx/merge/ |
| MergeTest.java | 44 private static final ExecutorService executor = Executors.newFixedThreadPool(WORKER_THREADS); field in class:MergeTest
99 executor.execute(new MergeTask(fileNames, dexesToMerge));
102 executor.shutdown();
103 executor.awaitTermination(8, TimeUnit.HOURS);
|
| /external/conscrypt/testing/src/main/java/org/conscrypt/javax/net/ssl/ |
| TestSSLSocketPair.java | 68 ExecutorService executor = Executors.newFixedThreadPool(2); local
69 Future<Void> s = executor.submit(new Callable<Void>() {
79 Future<Void> c = executor.submit(new Callable<Void>() {
89 executor.shutdown();
|
| /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);
|
| /libcore/support/src/test/java/libcore/javax/net/ssl/ |
| TestSSLSocketPair.java | 79 ExecutorService executor = Executors.newFixedThreadPool(2); local
80 Future s = executor.submit(new Callable<Void>() {
89 Future c = executor.submit(new Callable<Void>() {
98 executor.shutdown();
|
| /packages/apps/Camera2/src/com/android/camera/settings/ |
| SettingObserver.java | 22 import java.util.concurrent.Executor;
36 private final Executor mExecutor;
38 private Listener(Runnable runnable, Executor executor) {
40 mExecutor = executor;
87 public SafeCloseable addCallback(@Nonnull Runnable callback, @Nonnull Executor executor) {
88 Listener listener = new Listener(callback, executor);
|
| /packages/apps/Settings/tests/robotests/src/com/android/settings/testutils/shadow/ |
| ShadowRunnableAsyncTask.java | 25 import java.util.concurrent.Executor;
35 public AsyncTask<Params, Progress, Result> executeOnExecutor(Executor executor,
|
| /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);
|
| /external/tensorflow/tensorflow/compiler/xla/service/ |
| backend.cc | 109 se::StreamExecutor* executor) {
111 if (0 == stream_pools_.count(executor)) {
113 std::forward_as_tuple(executor),
114 std::forward_as_tuple([executor]() {
115 auto stream = MakeUnique<se::Stream>(executor);
120 return stream_pools_.at(executor).Allocate();
189 for (auto* executor : stream_executors_) {
190 if (executor->device_ordinal() == device_ordinal) {
191 return executor;
|
| /external/webrtc/webrtc/examples/androidapp/src/org/appspot/apprtc/ |
| WebSocketChannelClient.java | 33 * <p>All public methods should be called from a looper executor thread
42 private final LooperExecutor executor; field in class:WebSocketChannelClient
65 * All events are dispatched from a looper executor thread.
73 public WebSocketChannelClient(LooperExecutor executor, WebSocketChannelEvents events) {
74 this.executor = executor;
208 executor.execute(new Runnable() {
240 if (!executor.checkOnLooperThread()) {
250 executor.execute(new Runnable() {
270 executor.execute(new Runnable()
[all...] |
| /frameworks/base/telephony/java/android/telephony/ |
| MbmsStreamingSession.java | 45 import java.util.concurrent.Executor;
91 private MbmsStreamingSession(Context context, Executor executor, int subscriptionId,
95 mInternalCallback = new InternalStreamingSessionCallback(callback, executor);
116 * @param executor The executor on which you wish to execute callbacks.
123 @NonNull Executor executor, int subscriptionId,
128 MbmsStreamingSession session = new MbmsStreamingSession(context, executor,
134 executor.execute(new Runnable()
[all...] |
| /frameworks/support/lifecycle/livedata/src/test/java/androidx/lifecycle/ |
| ComputableLiveDataTest.java | 32 import androidx.arch.core.executor.ArchTaskExecutor;
33 import androidx.arch.core.executor.TaskExecutor;
34 import androidx.arch.core.executor.TaskExecutorWithFakeMainThread;
45 import java.util.concurrent.Executor;
80 TaskExecutorWithFakeMainThread executor = new TaskExecutorWithFakeMainThread(2); local
81 ArchTaskExecutor.getInstance().setDelegate(executor);
102 executor.postToMainThread(new Runnable() {
127 executor.drainTasks(2);
156 Executor customExecutor = mock(Executor.class)
[all...] |
| /frameworks/base/core/java/android/hardware/camera2/ |
| CameraManager.java | 49 import java.util.concurrent.Executor;
145 * except that it uses {@link java.util.concurrent.Executor} as an argument
148 * @param executor The executor which will be used to invoke the callback.
151 * @throws IllegalArgumentException if the executor is {@code null}.
153 public void registerAvailabilityCallback(@NonNull @CallbackExecutor Executor executor,
155 if (executor == null) {
156 throw new IllegalArgumentException("executor was null");
158 CameraManagerGlobal.get().registerAvailabilityCallback(callback, executor);
1158 Executor executor = mCallbackMap.valueAt(i); local
1197 final Executor executor = mTorchCallbackMap.valueAt(i); local
[all...] |
| /external/deqp/framework/randomshaders/ |
| rsgTest.cpp | 68 rsg::ProgramExecutor executor(surface.getAccess(), 3, 5);
70 executor.execute(vertexShader, fragmentShader, uniformValues);
|
