Home
last modified time | relevance | path

Searched refs:Executor (Results 1 – 25 of 190) sorted by relevance

12345678

/external/swiftshader/third_party/llvm-7.0/llvm/lib/Support/
DParallel.cpp26 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/
Dmulti_thread_gemm.h28 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 …]
Dtest_gemm_correctness.cc73 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/
DHttp2Ping.java23 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()
DConnectivityStateManager.java24 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()
DSerializingExecutor.java24 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/
DExecutionListBenchmark.java33 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 …]
DMoreExecutorsDirectExecutorBenchmark.java31 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()
DFuturesCombineBenchmark.java29 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/
DJdkFutureAdapters.java24 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()
DExecutionList.java22 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()
DAbstractExecutionThreadService.java23 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) {
DSerializingExecutor.java23 import java.util.concurrent.Executor;
46 final class SerializingExecutor implements Executor {
51 private final Executor executor;
76 public SerializingExecutor(Executor executor) { in SerializingExecutor()
DAbstractIdleService.java23 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/
DAsyncEventBus.java24 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/
DSendPingCommand.java20 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/
DExecutorFactory.java20 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/
DAbstractExecutionThreadServiceTest.java26 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/
Dindex.rst13 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/
DSerializingExecutorTest.java29 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/
DCronetClientStreamTest.java52 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/
DExecutorDelivery.java20 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/
DContext.java23 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/
Dexecutor_factory.h28 class Executor; variable
36 std::unique_ptr<Executor>* out_executor) = 0;
47 std::unique_ptr<Executor>* out_executor);
/external/python/cpython3/Doc/library/
Dconcurrent.futures.rst20 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 …]

12345678