/external/tensorflow/tensorflow/core/kernels/hexagon/ |
hexagon_remote_fused_graph_executor_build_test.cc | 25 std::unique_ptr<IRemoteFusedGraphExecutor>* executor); 30 std::unique_ptr<IRemoteFusedGraphExecutor> executor; local 31 ASSERT_FALSE(static_cast<bool>(executor)); 32 TF_ASSERT_OK(BuildRemoteFusedGraphExecutor(&executor)); 33 ASSERT_TRUE(static_cast<bool>(executor));
|
hexagon_remote_fused_graph_executor_build.cc | 23 std::unique_ptr<IRemoteFusedGraphExecutor>* executor) { 24 executor->reset(new HexagonControlWrapper());
|
/packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
MockNamedTaskExecutorFactory.java | 30 * Runs one task in each executor. 33 for (MockNamedTaskExecutor executor : mExecutors) { 34 executor.runNext(); 39 MockNamedTaskExecutor executor = new MockNamedTaskExecutor(); local 40 mExecutors.add(executor); 41 return executor;
|
/external/glide/library/src/main/java/com/bumptech/glide/load/engine/executor/ |
Prioritized.java | 1 package com.bumptech.glide.load.engine.executor;
|
/packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
PerNameExecutor.java | 23 * Uses a separate executor for each task name. 39 for (NamedTaskExecutor executor : mExecutors.values()) { 40 executor.cancelPendingTasks(); 46 for (NamedTaskExecutor executor : mExecutors.values()) { 47 executor.close(); 56 NamedTaskExecutor executor = mExecutors.get(name); local 57 if (executor == null) { 58 executor = mExecutorFactory.create(); 59 mExecutors.put(name, executor); 61 executor.execute(task) [all...] |
/libcore/ojluni/src/main/java/java/util/concurrent/ |
RejectedExecutionHandler.java | 51 * shutdown of the Executor. 58 * @param executor the executor attempting to execute this task 61 void rejectedExecution(Runnable r, ThreadPoolExecutor executor);
|
ExecutorCompletionService.java | 39 * A {@link CompletionService} that uses a supplied {@link Executor} 56 * void solve(Executor e, 76 * void solve(Executor e, 107 private final Executor executor; field in class:ExecutorCompletionService 142 * executor for base task execution and a 145 * @param executor the executor to use 146 * @throws NullPointerException if executor is {@code null} 148 public ExecutorCompletionService(Executor executor) [all...] |
/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/guava/guava/src/com/google/common/util/concurrent/ |
ExecutionList.java | 22 import java.util.concurrent.Executor; 30 * <p>A list of listeners, each with an associated {@code Executor}, that 37 * <p>Exceptions thrown by a listener will be propagated up to the executor. 38 * Any exception thrown during {@code Executor.execute} (e.g., a {@code 52 * The runnable, executor pairs to execute. This acts as a stack threaded through the 64 * Adds the {@code Runnable} and accompanying {@code Executor} to the list of 81 public void add(Runnable runnable, Executor executor) { 83 // Executor states that it throws NPE on null listener, so we propagate 86 Preconditions.checkNotNull(executor, "Executor was null.") 168 final Executor executor; field in class:ExecutionList.RunnableExecutorPair [all...] |
SerializingExecutor.java | 23 import java.util.concurrent.Executor; 30 * Executor ensuring that all Runnables submitted are executed in order, 31 * using the provided Executor, and serially such that no two will ever 34 * TODO(user): The tasks are given to the underlying executor as a single 35 * task, which means the semantics of the executor may be changed, e.g. the 36 * executor may have an afterExecute method that runs after every task 46 final class SerializingExecutor implements Executor { 50 /** Underlying executor that all submitted Runnable objects are run on. */ 51 private final Executor executor; field in class:SerializingExecutor [all...] |
/external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
gpu_transfer_manager.h | 39 Status TransferLiteralToInfeed(perftools::gputools::StreamExecutor* executor, 41 Status TransferBufferToInfeed(perftools::gputools::StreamExecutor* executor, 48 perftools::gputools::StreamExecutor* executor, int64 size, 53 Status EnqueueBuffersToInfeed(perftools::gputools::StreamExecutor* executor,
|
/frameworks/base/core/java/android/hardware/camera2/utils/ |
TaskSingleDrainer.java | 20 import java.util.concurrent.Executor; 42 * via the {@code executor}. 44 * @param executor a non-{@code null} executor to use for listener execution 47 public TaskSingleDrainer(Executor executor, DrainListener listener) { 48 mTaskDrainer = new TaskDrainer<>(executor, listener); 53 * via the {@code executor}. 55 * @param executor a non-{@code null} executor to use for listener executio [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/Camera2/src/com/android/camera/one/v2/commands/ |
RunnableCameraCommand.java | 27 public RunnableCameraCommand(CameraCommandExecutor executor, CameraCommand command) { 28 mExecutor = executor;
|
/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;
|
/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
MoreExecutorsDirectExecutorBenchmark.java | 31 import java.util.concurrent.Executor; 42 @Override Executor executor() { method 46 EXECUTOR { 47 @Override Executor executor() { method 51 abstract Executor executor(); method in class:MoreExecutorsDirectExecutorBenchmark.Impl 55 Executor executor; field in class:MoreExecutorsDirectExecutorBenchmark 96 final Executor executor = this.executor; local 105 final Executor executor = this.executor; local [all...] |
/external/tensorflow/tensorflow/compiler/xla/service/cpu/ |
cpu_transfer_manager.h | 40 Status TransferLiteralToInfeed(perftools::gputools::StreamExecutor* executor, 42 Status TransferBufferToInfeed(perftools::gputools::StreamExecutor* executor, 45 perftools::gputools::StreamExecutor* executor, const Shape& literal_shape, 52 perftools::gputools::StreamExecutor* executor, int64 size, 57 perftools::gputools::StreamExecutor* executor, 62 perftools::gputools::StreamExecutor* executor, void* destination, 69 perftools::gputools::StreamExecutor* executor,
|
/external/webrtc/webrtc/examples/androidtests/src/org/appspot/apprtc/test/ |
LooperExecutorTest.java | 38 LooperExecutor executor = new LooperExecutor(); local 40 // Try to execute a counter increment task before starting an executor. 41 executor.execute(counterIncRunnable); 43 // Start the executor and run expected amount of counter increment task. 44 executor.requestStart(); 46 executor.execute(counterIncRunnable); 48 executor.execute(new Runnable() { 54 executor.requestStop(); 56 // Try to execute a task after stopping the executor. 57 executor.execute(counterIncRunnable) [all...] |
/frameworks/base/tools/aapt2/xml/ |
XmlActionExecutor_test.cpp | 27 XmlActionExecutor executor; local 28 XmlNodeAction& manifest_action = executor["manifest"]; 47 ASSERT_TRUE(executor.Execute(XmlActionExecutorPolicy::kNone, &diag, doc.get())); 56 XmlActionExecutor executor; local 57 executor["manifest"]["application"]; 63 ASSERT_FALSE(executor.Execute(XmlActionExecutorPolicy::kWhitelist, &diag, doc.get())); 66 ASSERT_FALSE(executor.Execute(XmlActionExecutorPolicy::kWhitelist, &diag, doc.get()));
|
/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() {
|
/external/tensorflow/tensorflow/compiler/xla/service/ |
transfer_manager.h | 56 // using the provided executor. The optional literal_shape will be the shape 61 perftools::gputools::StreamExecutor* executor, 65 // represented by the given ShapedBuffer using the given executor. The shape 69 perftools::gputools::StreamExecutor* executor, const Literal& literal, 76 perftools::gputools::StreamExecutor* executor, const Literal& literal, 79 perftools::gputools::StreamExecutor* executor, const Shape& shape, 83 // using the given executor. 85 perftools::gputools::StreamExecutor* executor, 89 // using the given executor. 91 perftools::gputools::StreamExecutor* executor, const Shape& literal_shape [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...] |
/libcore/ojluni/src/main/java/java/nio/channels/ |
AsynchronousChannelGroup.java | 193 * <p> The {@code executor} parameter is an {@code ExecutorService} that 204 * <p> The executor is intended to be used exclusively by the resulting 206 * orderly {@link ExecutorService#shutdown shutdown} of the executor 207 * service. Shutting down the executor service by other means results in 215 * @param executor 228 public static AsynchronousChannelGroup withCachedThreadPool(ExecutorService executor, 233 .openAsynchronousChannelGroup(executor, initialSize); 239 * <p> The {@code executor} parameter is an {@code ExecutorService} that 243 * <p> Care should be taken when configuring the executor service. It 249 * <p> The executor is intended to be used exclusively by the resultin [all...] |
/packages/inputmethods/LatinIME/native/dicttoolkit/ |
dict_toolkit_main.cpp | 37 const auto executor = CommandUtils::getCommandExecutor(commandType); local 38 return executor(argc - 1, argv + 1);
|
/external/guice/extensions/service/src/com/google/inject/service/ |
AsyncService.java | 37 private final ExecutorService executor; field in class:AsyncService 41 public AsyncService(ExecutorService executor) { 42 this.executor = executor; 54 return executor.submit(new Callable<State>() { 79 return executor.submit(new Callable<State>() {
|