| /external/tensorflow/tensorflow/compiler/xla/service/ |
| local_service.cc | 141 se::StreamExecutor * executor,
145 execute_backend_.get(), executor,
|
| /frameworks/base/core/java/android/widget/ |
| VideoView2.java | 46 import java.util.concurrent.Executor;
367 * @param executor executor to run callbacks on.
372 Executor executor, OnCustomActionListener listener) {
373 mProvider.setCustomActions_impl(actionList, executor, listener);
|
| /frameworks/base/media/java/android/media/ |
| MediaPlaylistAgent.java | 29 import java.util.concurrent.Executor;
101 * {@link MediaPlaylistAgent#registerPlaylistEventCallback(Executor, PlaylistEventCallback)}
158 * @param executor a callback Executor
160 * @throws IllegalArgumentException if executor or callback is {@code null}.
163 @NonNull @CallbackExecutor Executor executor, @NonNull PlaylistEventCallback callback) {
164 mProvider.registerPlaylistEventCallback_impl(executor, callback);
|
| MediaController2.java | 40 import java.util.concurrent.Executor;
345 * @param executor executor to run callbacks on.
349 @NonNull @CallbackExecutor Executor executor, @NonNull ControllerCallback callback) {
352 mProvider = createProvider(context, token, executor, callback);
362 @NonNull SessionToken2 token, @NonNull Executor executor,
365 context, this, token, executor, callback);
|
| /frameworks/ml/nn/driver/sample/ |
| SampleDriver.cpp | 122 CpuExecutor executor; local
123 int n = executor.run(mModel, request, mPoolInfos, requestPoolInfos);
124 VLOG(DRIVER) << "executor.run returned " << n;
|
| /frameworks/support/app-toolkit/core-testing/src/androidTest/java/androidx/arch/core/executor/testing/ |
| CountingTaskExecutorRuleTest.java | 17 package androidx.arch.core.executor.testing;
25 import androidx.arch.core.executor.ArchTaskExecutor;
|
| /frameworks/support/lifecycle/reactivestreams/ktx/src/test/java/androidx/lifecycle/ |
| LiveDataReactiveStreamsTest.kt | 19 import androidx.arch.core.executor.testing.InstantTaskExecutorRule
|
| /frameworks/support/work/workmanager/src/main/java/androidx/work/impl/ |
| Processor.java | 31 import java.util.concurrent.Executor;
47 private Executor mExecutor;
58 Executor executor) {
64 mExecutor = executor;
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| SynchronousQueueTest.java | 474 * offer transfers elements across Executor tasks
481 final ExecutorService executor = Executors.newFixedThreadPool(2);
482 try (PoolCleaner cleaner = cleaner(executor)) {
484 executor.execute(new CheckedRunnable() {
492 executor.execute(new CheckedRunnable() {
501 * timed poll retrieves elements across Executor threads
508 final ExecutorService executor = Executors.newFixedThreadPool(2);
509 try (PoolCleaner cleaner = cleaner(executor)) {
510 executor.execute(new CheckedRunnable() {
518 executor.execute(new CheckedRunnable()
[all...] |
| /packages/apps/Dialer/java/com/android/dialer/common/concurrent/ |
| DialerUiTaskFragment.java | 31 import java.util.concurrent.Executor;
50 private Executor parallelExecutor;
84 @NonNull Executor parallelExecutor) {
138 void executeOnCustomExecutor(ExecutorService executor, InputT input) {
139 executor.execute(() -> runTask(input));
|
| /external/dagger2/compiler/src/it/producers-functional-tests/src/test/java/producerstest/badexecutor/ |
| BadExecutorTest.java | 17 /** This test verifies behavior when the executor throws {@link RejectedExecutionException}. */
34 .executor(executorService)
|
| /external/glide/library/src/main/java/com/bumptech/glide/load/engine/ |
| EngineRunnable.java | 6 import com.bumptech.glide.load.engine.executor.Prioritized;
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/framed/ |
| MockSpdyPeer.java | 51 private final ExecutorService executor = Executors.newSingleThreadExecutor( field in class:MockSpdyPeer
122 executor.execute(new Runnable() {
140 if (executor.isShutdown()) {
194 executor.shutdown();
|
| /external/python/futures/concurrent/futures/ |
| process.py | 18 | Executor | | Thread | | |
27 Executor.submit() called:
220 executor = executor_reference()
223 # - The executor that owns this worker has been collected OR
224 # - The executor that owns this worker has been shutdown.
225 if _shutdown or executor is None or executor._shutdown_thread:
238 del executor
266 class ProcessPoolExecutor(_base.Executor):
302 # When the executor gets lost, the weakref callback will wake u
[all...] |
| /external/skia/src/core/ |
| SkThreadedBMPDevice.cpp | 46 SkExecutor* executor)
52 if (executor == nullptr) {
54 executor = fInternalExecutor.get();
56 fExecutor = executor;
|
| /external/skqp/src/core/ |
| SkThreadedBMPDevice.cpp | 39 SkExecutor* executor)
45 if (executor == nullptr) {
47 executor = fInternalExecutor.get();
49 fExecutor = executor;
|
| /external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| gpu_executable.cc | 277 se::StreamExecutor* executor = run_options->stream()->parent(); local
280 buffer_allocations_builder.Build(*assignment_, executor->device_ordinal(),
290 auto device_ordinal = executor->device_ordinal();
292 root->shape(), root->shape(), executor->platform(), device_ordinal);
|
| /frameworks/av/packages/MediaComponents/src/com/android/media/update/ |
| ApiFactory.java | 83 import java.util.concurrent.Executor;
96 Executor executor, ControllerCallback callback) {
97 return new MediaController2Impl(context, instance, token, executor, callback);
102 SessionToken2 token, Executor executor, BrowserCallback callback) {
103 return new MediaBrowser2Impl(context, instance, token, executor, callback);
171 MediaLibrarySession.Builder instance, Executor callbackExecutor,
|
| /frameworks/base/media/java/android/media/update/ |
| VideoView2Provider.java | 38 import java.util.concurrent.Executor;
89 Executor executor, VideoView2.OnCustomActionListener listener);
|
| /frameworks/support/media-widget/src/main/java/androidx/media/widget/ |
| VideoView2Impl.java | 38 import java.util.concurrent.Executor;
221 * @param executor executor to run callbacks on.
225 Executor executor, VideoView2.OnCustomActionListener listener);
|
| /frameworks/support/room/integration-tests/testapp/src/androidTest/java/androidx/room/integration/testapp/test/ |
| WriteAheadLoggingTest.java | 150 ExecutorService executor = Executors.newFixedThreadPool(numberOfThreads); local
154 futures.add(i, executor.submit(() -> {
179 ExecutorService executor = Executors.newSingleThreadExecutor(); local
180 Future<?> future = executor.submit(() ->
|
| /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() {
|
| /frameworks/support/slices/view/src/main/java/androidx/slice/ |
| SliceManager.java | 33 import java.util.concurrent.Executor;
87 public abstract void registerSliceCallback(@NonNull Uri uri, @NonNull Executor executor,
|
| /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();
|
| /libcore/ojluni/src/main/java/java/nio/channels/spi/ |
| AsynchronousChannelProvider.java | 192 * @param executor
206 openAsynchronousChannelGroup(ExecutorService executor, int initialSize) throws IOException;
|
