| /external/llvm-project/clang/unittests/Tooling/ |
| D | ExecutionTest.cpp | 142 auto Executor = internal::createExecutorFromCommandLineArgsImpl( in TEST() local
144 ASSERT_FALSE((bool)Executor); in TEST()
145 llvm::consumeError(Executor.takeError()); in TEST()
157 auto Executor = internal::createExecutorFromCommandLineArgsImpl( in TEST() local
159 ASSERT_TRUE((bool)Executor); in TEST()
167 auto Executor = internal::createExecutorFromCommandLineArgsImpl( in TEST() local
169 ASSERT_TRUE((bool)Executor); in TEST()
170 EXPECT_EQ(Executor->get()->getExecutorName(), in TEST()
178 auto Executor = internal::createExecutorFromCommandLineArgsImpl( in TEST() local
180 ASSERT_TRUE((bool)Executor); in TEST()
[all …]
|
| /external/crosvm/cros_async/src/ |
| D | executor.rs | 120 pub enum Executor { enum
125 impl Executor { implementation
129 Ok(URingExecutor::new().map(Executor::Uring)?) in new()
132 .map(Executor::Fd) in new()
133 .map_err(PollError::Executor)?) in new()
145 Executor::Uring(ex) => async_uring_from(f, ex), in async_from()
146 Executor::Fd(ex) => async_poll_from(f, ex), in async_from()
187 Executor::Uring(ex) => ex.spawn(f), in spawn()
188 Executor::Fd(ex) => ex.spawn(f), in spawn()
225 Executor::Uring(ex) => ex.spawn_local(f), in spawn_local()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | executor.cc | 58 Executor* executors[static_cast<size_t>(ExecutorType::NUM_EXECUTORS)];
92 Executor::Executor(const char* name) : name_(name) { in Executor() function in grpc_core::Executor
98 void Executor::Init() { SetThreading(true); } in Init()
100 size_t Executor::RunClosures(const char* executor_name, in RunClosures()
136 bool Executor::IsThreaded() const { in IsThreaded()
140 void Executor::SetThreading(bool threading) { in SetThreading()
165 grpc_core::Thread(name_, &Executor::ThreadMain, &thd_state_[0]); in SetThreading()
213 void Executor::Shutdown() { SetThreading(false); } in Shutdown()
215 void Executor::ThreadMain(void* arg) { in ThreadMain()
254 void Executor::Enqueue(grpc_closure* closure, grpc_error* error, in Enqueue()
[all …]
|
| /external/gemmlowp/meta/ |
| D | multi_thread_gemm.h | 28 template <typename Executor, typename Params>
52 return scratch + Executor::template EstimateScratchSize<Params>( in PrepareGemmTask()
56 template <typename MultiThreadingContext, typename Executor, typename Params>
80 scratch = PrepareGemmTask<Executor, Params>( in PrepareGemmTasks()
85 PrepareGemmTask<Executor, Params>(params, kernel_m, kernel_n, kernel_k, in PrepareGemmTasks()
91 scratch = PrepareGemmTask<Executor, Params>( in PrepareGemmTasks()
96 PrepareGemmTask<Executor, Params>(params, kernel_m, kernel_n, kernel_k, in PrepareGemmTasks()
104 template <typename Executor, typename Params, int kernel_m, int kernel_n,
110 Gemm<Executor, Params, kernel_m, kernel_n, kernel_k>(params); in Run()
118 template <typename MultiThreadingContext, typename Executor, typename Params,
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | Http2Ping.java | 23 import java.util.concurrent.Executor;
53 @GuardedBy("this") private Map<PingCallback, Executor> callbacks
54 = new LinkedHashMap<PingCallback, Executor>();
93 public void addCallback(final ClientTransport.PingCallback callback, Executor executor) { in addCallback()
124 Map<ClientTransport.PingCallback, Executor> callbacks; in complete()
135 for (Map.Entry<ClientTransport.PingCallback, Executor> entry : callbacks.entrySet()) { in complete()
148 Map<ClientTransport.PingCallback, Executor> callbacks; in failed()
158 for (Map.Entry<ClientTransport.PingCallback, Executor> entry : callbacks.entrySet()) { in failed()
170 public static void notifyFailed(PingCallback callback, Executor executor, Throwable cause) { in notifyFailed()
178 private static void doExecute(Executor executor, Runnable runnable) { in doExecute()
|
| /external/exoplayer/tree/extensions/cronet/src/main/java/com/google/android/exoplayer2/ext/cronet/ |
| D | CronetDataSourceFactory.java | 24 import java.util.concurrent.Executor;
45 private final Executor executor;
69 Executor executor, in CronetDataSourceFactory()
97 Executor executor, in CronetDataSourceFactory()
129 Executor executor, in CronetDataSourceFactory()
165 Executor executor, in CronetDataSourceFactory()
198 Executor executor, in CronetDataSourceFactory()
228 Executor executor, in CronetDataSourceFactory()
262 Executor executor, in CronetDataSourceFactory()
296 Executor executor, in CronetDataSourceFactory()
|
| /external/guava/android/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | ExecutionListBenchmark.java | 34 import java.util.concurrent.Executor;
50 void add(Runnable runnable, Executor executor); in add()
65 public void add(Runnable runnable, Executor executor) { in newExecutionList()
88 public void add(Runnable runnable, Executor executor) { in newExecutionList()
111 public void add(Runnable runnable, Executor executor) { in newExecutionList()
134 public void add(Runnable runnable, Executor executor) {
157 public void add(Runnable runnable, Executor executor) {
180 public void add(Runnable runnable, Executor executor) {
204 public void add(Runnable runnable, Executor executor) {
272 @Footprint(exclude = {Runnable.class, Executor.class})
[all …]
|
| D | MoreExecutorsDirectExecutorBenchmark.java | 30 import java.util.concurrent.Executor;
42 Executor executor() { in executor()
48 Executor executor() { in executor()
53 abstract Executor executor(); in executor()
57 Executor executor;
106 final Executor executor = this.executor; in timeUncontendedExecute()
116 final Executor executor = this.executor; in timeContendedExecute()
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | ExecutionListBenchmark.java | 34 import java.util.concurrent.Executor;
50 void add(Runnable runnable, Executor executor); in add()
65 public void add(Runnable runnable, Executor executor) { in newExecutionList()
88 public void add(Runnable runnable, Executor executor) { in newExecutionList()
111 public void add(Runnable runnable, Executor executor) { in newExecutionList()
134 public void add(Runnable runnable, Executor executor) {
157 public void add(Runnable runnable, Executor executor) {
180 public void add(Runnable runnable, Executor executor) {
204 public void add(Runnable runnable, Executor executor) {
272 @Footprint(exclude = {Runnable.class, Executor.class})
[all …]
|
| D | MoreExecutorsDirectExecutorBenchmark.java | 30 import java.util.concurrent.Executor;
42 Executor executor() { in executor()
48 Executor executor() { in executor()
53 abstract Executor executor(); in executor()
57 Executor executor;
106 final Executor executor = this.executor; in timeUncontendedExecute()
116 final Executor executor = this.executor; in timeContendedExecute()
|
| /external/llvm-project/clang-tools-extra/tool-template/ |
| D | ToolTemplate.cpp | 93 auto Executor = clang::tooling::createExecutorFromCommandLineArgs( in main() local
96 if (!Executor) { in main()
97 llvm::errs() << llvm::toString(Executor.takeError()) << "\n"; in main()
102 ToolTemplateCallback Callback(*Executor->get()->getExecutionContext()); in main()
113 auto Err = Executor->get()->execute(newFrontendActionFactory(&Finder)); in main()
117 Executor->get()->getToolResults()->forEachResult( in main()
|
| /external/swiftshader/third_party/llvm-10.0/llvm/lib/Support/ |
| D | Parallel.cpp | 30 class Executor { class
32 virtual ~Executor() = default;
35 static Executor *getDefaultExecutor();
40 class ThreadPoolExecutor : public Executor {
114 Executor *Executor::getDefaultExecutor() { in getDefaultExecutor()
152 Executor::getDefaultExecutor()->add([&, F] { in spawn()
|
| /external/llvm-project/llvm/lib/Support/ |
| D | Parallel.cpp | 31 class Executor { class
33 virtual ~Executor() = default;
36 static Executor *getDefaultExecutor();
41 class ThreadPoolExecutor : public Executor {
120 Executor *Executor::getDefaultExecutor() { in getDefaultExecutor()
159 Executor::getDefaultExecutor()->add([&, F] { in spawn()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | JdkFutureAdapters.java | 22 import java.util.concurrent.Executor;
79 public static <V> ListenableFuture<V> listenInPoolThread(Future<V> future, Executor executor) { in listenInPoolThread()
104 private static final Executor defaultAdapterExecutor =
107 private final Executor adapterExecutor;
123 ListenableFutureAdapter(Future<V> delegate, Executor adapterExecutor) { in ListenableFutureAdapter()
134 public void addListener(Runnable listener, Executor exec) { in addListener()
|
| D | ExecutionSequencer.java | 29 import java.util.concurrent.Executor;
129 Executor nextExecutor;
139 public <T> ListenableFuture<T> submit(final Callable<T> callable, Executor executor) { in submit()
165 final AsyncCallable<T> callable, final Executor executor) {
284 implements Executor, Runnable {
296 Executor delegate;
307 private TaskNonReentrantExecutor(Executor delegate, ExecutionSequencer sequencer) {
343 Executor localDelegate = delegate;
389 Executor queuedExecutor;
|
| D | FluentFuture.java | 26 import java.util.concurrent.Executor;
107 public final void addListener(Runnable listener, Executor executor) { in addListener()
183 Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) { in catching()
247 Class<X> exceptionType, AsyncFunction<? super X, ? extends V> fallback, Executor executor) { in catchingAsync()
308 AsyncFunction<? super V, T> function, Executor executor) { in transformAsync()
344 public final <T> FluentFuture<T> transform(Function<? super V, T> function, Executor executor) { in transform()
385 public final void addCallback(FutureCallback<? super V> callback, Executor executor) { in addCallback()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | JdkFutureAdapters.java | 22 import java.util.concurrent.Executor;
79 public static <V> ListenableFuture<V> listenInPoolThread(Future<V> future, Executor executor) { in listenInPoolThread()
104 private static final Executor defaultAdapterExecutor =
107 private final Executor adapterExecutor;
123 ListenableFutureAdapter(Future<V> delegate, Executor adapterExecutor) { in ListenableFutureAdapter()
134 public void addListener(Runnable listener, Executor exec) { in addListener()
|
| D | ExecutionSequencer.java | 29 import java.util.concurrent.Executor;
129 Executor nextExecutor;
139 public <T> ListenableFuture<T> submit(final Callable<T> callable, Executor executor) { in submit()
165 final AsyncCallable<T> callable, final Executor executor) {
284 implements Executor, Runnable {
296 Executor delegate;
307 private TaskNonReentrantExecutor(Executor delegate, ExecutionSequencer sequencer) {
343 Executor localDelegate = delegate;
389 Executor queuedExecutor;
|
| D | CombinedFuture.java | 26 import java.util.concurrent.Executor;
38 Executor listenerExecutor, in CombinedFuture()
48 Executor listenerExecutor, in CombinedFuture()
91 private final Executor listenerExecutor;
93 CombinedFutureInterruptibleTask(Executor listenerExecutor) { in CombinedFutureInterruptibleTask()
146 AsyncCallableInterruptibleTask(AsyncCallable<V> callable, Executor listenerExecutor) { in AsyncCallableInterruptibleTask()
176 CallableInterruptibleTask(Callable<V> callable, Executor listenerExecutor) { in CallableInterruptibleTask()
|
| D | FluentFuture.java | 28 import java.util.concurrent.Executor;
109 public final void addListener(Runnable listener, Executor executor) { in addListener()
185 Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) { in catching()
249 Class<X> exceptionType, AsyncFunction<? super X, ? extends V> fallback, Executor executor) { in catchingAsync()
326 AsyncFunction<? super V, T> function, Executor executor) { in transformAsync()
362 public final <T> FluentFuture<T> transform(Function<? super V, T> function, Executor executor) { in transform()
403 public final void addCallback(FutureCallback<? super V> callback, Executor executor) { in addCallback()
|
| /external/deqp-deps/amber/src/ |
| D | executor_test.cc | 245 Executor ex; in TEST_F()
275 Executor ex; in TEST_F()
305 Executor ex; in TEST_F()
332 Executor ex; in TEST_F()
367 Executor ex; in TEST_F()
398 Executor ex; in TEST_F()
419 Executor ex; in TEST_F()
439 Executor ex; in TEST_F()
469 Executor ex; in TEST_F()
489 Executor ex; in TEST_F()
[all …]
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | SendPingCommand.java | 20 import java.util.concurrent.Executor;
27 private final Executor executor;
29 SendPingCommand(PingCallback callback, Executor executor) { in SendPingCommand()
38 Executor executor() { in executor()
|
| /external/dagger2/javatests/dagger/functional/producers/ |
| D | ExecutorModule.java | 23 import java.util.concurrent.Executor;
31 private final Executor executor;
37 public ExecutorModule(Executor executor) { in ExecutorModule()
43 Executor executor() { in executor()
|
| /external/guava/guava/src/com/google/common/eventbus/ |
| D | AsyncEventBus.java | 18 import java.util.concurrent.Executor;
38 public AsyncEventBus(String identifier, Executor executor) { in AsyncEventBus()
51 public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) { in AsyncEventBus()
61 public AsyncEventBus(Executor executor) { in AsyncEventBus()
|
| /external/guava/android/guava/src/com/google/common/eventbus/ |
| D | AsyncEventBus.java | 18 import java.util.concurrent.Executor;
38 public AsyncEventBus(String identifier, Executor executor) { in AsyncEventBus()
51 public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) { in AsyncEventBus()
61 public AsyncEventBus(Executor executor) { in AsyncEventBus()
|