/external/swiftshader/third_party/llvm-7.0/llvm/lib/Support/ |
D | Parallel.cpp | 26 class Executor { class 28 virtual ~Executor() = default; 31 static Executor *getDefaultExecutor(); 36 class ConcRTExecutor : public Executor { 56 Executor *Executor::getDefaultExecutor() { in getDefaultExecutor() 64 class ThreadPoolExecutor : public Executor { 115 Executor *Executor::getDefaultExecutor() { in getDefaultExecutor() 124 Executor::getDefaultExecutor()->add([&, F] { in spawn()
|
/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 …]
|
D | test_gemm_correctness.cc | 73 typedef GemmExecutorPackLHSCacheFriendly<> Executor; typedef 75 typedef GemmExecutorPackRHSCacheFriendly<> Executor; typedef 379 Gemm<Executor, ParamsRowMajor, 2, 4, 8>(params_row); in main() 389 Gemm<Executor, ParamsColumnMajor, 2, 4, 8>(params_col); in main() 399 Gemm<Executor, ParamsRowMajorAsFloat, 2, 4, 8>(params_row_f); in main() 409 Gemm<Executor, ParamsColumnMajorAsFloat, 2, 4, 8>(params_col_f); in main() 419 Gemm<Executor, ParamsRowMajorAsInt32, 2, 4, 8>(params_row_i32); in main() 430 Gemm<Executor, ParamsColumnMajorAsInt32, 2, 4, 8>(params_col_i32); in main() 450 MultiThreadGemm<Context, Executor, ParamsRowMajor, 2, 4, 8>(&context, in main() 461 MultiThreadGemm<Context, Executor, ParamsColumnMajor, 2, 4, 8>( in main() [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()
|
D | ConnectivityStateManager.java | 24 import java.util.concurrent.Executor; 45 void notifyWhenStateChanged(Runnable callback, Executor executor, ConnectivityState source) { in notifyWhenStateChanged() 92 final Executor executor; 94 Listener(Runnable callback, Executor executor) { in Listener()
|
D | SerializingExecutor.java | 24 import java.util.concurrent.Executor; 36 public final class SerializingExecutor implements Executor, Runnable { 62 private final Executor executor; 74 public SerializingExecutor(Executor executor) { in SerializingExecutor()
|
/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
D | ExecutionListBenchmark.java | 33 import java.util.concurrent.Executor; 53 void add(Runnable runnable, Executor executor); in add() 64 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList() 82 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList() 100 @Override public void add(Runnable runnable, Executor executor) { in newExecutionList() 118 @Override public void add(Runnable runnable, Executor executor) { 136 @Override public void add(Runnable runnable, Executor executor) { 186 @Footprint(exclude = {Runnable.class, Executor.class}) 281 public void add(Runnable runnable, Executor executor) { 315 final Executor executor; [all …]
|
D | MoreExecutorsDirectExecutorBenchmark.java | 31 import java.util.concurrent.Executor; 42 @Override Executor executor() { in executor() 47 @Override Executor executor() { in executor() 51 abstract Executor executor(); in executor() 55 Executor executor; 96 final Executor executor = this.executor; in timeUncontendedExecute() 105 final Executor executor = this.executor; in timeContendedExecute()
|
D | FuturesCombineBenchmark.java | 29 import java.util.concurrent.Executor; 39 @Override <V> ListenableFuture<V> combine(final Callable<V> combiner, Executor executor, in combine() 59 <V> ListenableFuture<V> combine(Callable<V> combiner, final Executor executor, 66 Callable<V> combiner, Executor executor, 70 private static final Executor INLINE_EXECUTOR = new Executor() {
|
/external/guava/guava/src/com/google/common/util/concurrent/ |
D | JdkFutureAdapters.java | 24 import java.util.concurrent.Executor; 91 Future<V> future, Executor executor) { in listenInPoolThread() 117 private static final Executor defaultAdapterExecutor = 120 private final Executor adapterExecutor; 136 ListenableFutureAdapter(Future<V> delegate, Executor adapterExecutor) { in ListenableFutureAdapter() 147 public void addListener(Runnable listener, Executor exec) { in addListener()
|
D | ExecutionList.java | 22 import java.util.concurrent.Executor; 81 public void add(Runnable runnable, Executor executor) { in add() 154 private static void executeListener(Runnable runnable, Executor executor) { in executeListener() 168 final Executor executor; 171 RunnableExecutorPair(Runnable runnable, Executor executor, RunnableExecutorPair next) { in RunnableExecutorPair()
|
D | AbstractExecutionThreadService.java | 23 import java.util.concurrent.Executor; 46 Executor executor = MoreExecutors.renamingDecorator(executor(), new Supplier<String>() { 142 protected Executor executor() { in executor() 143 return new Executor() { in executor() 166 @Override public final void addListener(Listener listener, Executor executor) {
|
D | SerializingExecutor.java | 23 import java.util.concurrent.Executor; 46 final class SerializingExecutor implements Executor { 51 private final Executor executor; 76 public SerializingExecutor(Executor executor) { in SerializingExecutor()
|
D | AbstractIdleService.java | 23 import java.util.concurrent.Executor; 97 protected Executor executor() { in executor() 98 return new Executor() { in executor() 120 @Override public final void addListener(Listener listener, Executor executor) {
|
/external/guava/guava/src/com/google/common/eventbus/ |
D | AsyncEventBus.java | 24 import java.util.concurrent.Executor; 35 private final Executor executor; 50 public AsyncEventBus(String identifier, Executor executor) { in AsyncEventBus() 66 public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) { in AsyncEventBus() 79 public AsyncEventBus(Executor executor) { in AsyncEventBus()
|
/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/libchrome/mojo/public/java/bindings/src/org/chromium/mojo/bindings/ |
D | ExecutorFactory.java | 20 import java.util.concurrent.Executor; 42 private static class PipedExecutor implements Executor, Callback { 156 private static final ThreadLocal<Executor> EXECUTORS = new ThreadLocal<Executor>(); 161 public static Executor getExecutorForCurrentThread(Core core) { in getExecutorForCurrentThread() 162 Executor executor = EXECUTORS.get(); in getExecutorForCurrentThread()
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
D | AbstractExecutionThreadServiceTest.java | 26 import java.util.concurrent.Executor; 45 private final Executor exceptionCatchingExecutor = new Executor() { 158 @Override protected Executor executor() { in executor() 193 @Override protected Executor executor() { in executor() 247 @Override protected Executor executor() { in executor() 279 @Override protected Executor executor() { in executor() 296 @Override protected Executor executor() { in executor() 297 return new Executor() { in executor() 375 @Override protected Executor executor() { in executor()
|
/external/python/futures/docs/ |
D | index.rst | 13 defined by the abstract :class:`Executor` class. 15 Executor Objects 18 :class:`Executor` is an abstract class that provides methods to execute calls 22 .. method:: Executor.submit(fn, *args, **kwargs) 33 .. method:: Executor.map(func, *iterables, timeout=None) 44 .. method:: Executor.shutdown(wait=True) 48 :meth:`Executor.submit` and :meth:`Executor.map` made after shutdown will 60 statement, which will shutdown the `Executor` (waiting as if 61 `Executor.shutdown` were called with *wait* set to `True`): 76 The :class:`ThreadPoolExecutor` class is an :class:`Executor` subclass that uses [all …]
|
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
D | SerializingExecutorTest.java | 29 import java.util.concurrent.Executor; 55 class CoyExecutor implements Executor { in resumable() 163 ForwardingExecutor forwardingExecutor = new ForwardingExecutor(new Executor() { in firstExecuteThrows() 212 private static class SingleExecutor implements Executor { 232 private static class ForwardingExecutor implements Executor { 233 Executor executor; 235 public ForwardingExecutor(Executor executor) { in ForwardingExecutor()
|
/external/grpc-grpc-java/cronet/src/test/java/io/grpc/cronet/ |
D | CronetClientStreamTest.java | 52 import java.util.concurrent.Executor; 73 @Mock private Executor executor; 125 any(String.class), any(BidirectionalStream.Callback.class), any(Executor.class))) in setUp() 154 isA(String.class), callbackCaptor.capture(), isA(Executor.class)); in write() 234 isA(String.class), callbackCaptor.capture(), isA(Executor.class)); in read() 280 isA(String.class), callbackCaptor.capture(), isA(Executor.class)); in streamSucceeded() 346 isA(String.class), callbackCaptor.capture(), isA(Executor.class)); in streamSucceededWithGrpcError() 384 isA(String.class), callbackCaptor.capture(), isA(Executor.class)); in streamFailed() 408 isA(String.class), callbackCaptor.capture(), isA(Executor.class)); in streamFailedAfterResponseHeaderReceived() 436 isA(String.class), callbackCaptor.capture(), isA(Executor.class)); in streamFailedAfterTrailerReceived() [all …]
|
/external/volley/src/main/java/com/android/volley/ |
D | ExecutorDelivery.java | 20 import java.util.concurrent.Executor; 25 private final Executor mResponsePoster; 35 new Executor() { in ExecutorDelivery() 48 public ExecutorDelivery(Executor executor) { in ExecutorDelivery()
|
/external/grpc-grpc-java/context/src/main/java/io/grpc/ |
D | Context.java | 23 import java.util.concurrent.Executor; 461 final Executor executor) { in addListener() 630 public Executor fixedContextExecutor(final Executor e) { 631 class FixedContextExecutor implements Executor { 648 public static Executor currentContextExecutor(final Executor e) { 649 class CurrentContextExecutor implements Executor { 981 private final Executor executor; 984 private ExecutableListener(Executor executor, CancellationListener listener) { 1023 private enum DirectExecutor implements Executor {
|
/external/tensorflow/tensorflow/core/common_runtime/ |
D | executor_factory.h | 28 class Executor; variable 36 std::unique_ptr<Executor>* out_executor) = 0; 47 std::unique_ptr<Executor>* out_executor);
|
/external/python/cpython3/Doc/library/ |
D | concurrent.futures.rst | 20 defined by the abstract :class:`Executor` class. 23 Executor Objects 26 .. class:: Executor 52 after *timeout* seconds from the original call to :meth:`Executor.map`. 74 :meth:`Executor.submit` and :meth:`Executor.map` made after shutdown will 86 :keyword:`with` statement, which will shutdown the :class:`Executor` 87 (waiting as if :meth:`Executor.shutdown` were called with *wait* set to 101 :class:`ThreadPoolExecutor` is an :class:`Executor` subclass that uses a pool of 137 An :class:`Executor` subclass that uses a pool of at most *max_workers* 200 The :class:`ProcessPoolExecutor` class is an :class:`Executor` subclass that [all …]
|