| /external/executorch/kernels/portable/ |
| D | functions.yaml | 23 kernel_name: torch::executor::_cdist_forward_out
28 kernel_name: torch::executor::log_softmax_out
33 kernel_name: torch::executor::_native_batch_norm_legit_out
38 kernel_name: torch::executor::_native_batch_norm_legit_no_stats_out
43 kernel_name: torch::executor::_native_batch_norm_legit_no_training_out
48 kernel_name: torch::executor::_pdist_forward_out
53 kernel_name: torch::executor::softmax_out
58 kernel_name: torch::executor::to_copy_out
63 kernel_name: torch::executor::abs_out
68 kernel_name: torch::executor::acos_out
[all …]
|
| /external/sdv/vsomeip/third_party/boost/asio/include/boost/asio/ |
| D | executor.hpp | 2 // executor.hpp
34 /// Exception thrown when trying to access an empty polymorphic executor.
48 class executor class
52 executor() BOOST_ASIO_NOEXCEPT in executor() function in boost::asio::executor
58 executor(nullptr_t) BOOST_ASIO_NOEXCEPT in executor() function in boost::asio::executor
64 executor(const executor& other) BOOST_ASIO_NOEXCEPT in executor() function in boost::asio::executor
71 executor(executor&& other) BOOST_ASIO_NOEXCEPT in executor() function in boost::asio::executor
78 /// Construct a polymorphic wrapper for the specified executor.
79 template <typename Executor>
80 executor(Executor e);
[all …]
|
| D | strand.hpp | 22 #include <boost/asio/execution/executor.hpp>
30 /// Provides serialised function invocation for any executor type.
31 template <typename Executor>
35 /// The type of the underlying executor.
36 typedef Executor inner_executor_type;
40 * This constructor is only valid if the underlying executor type is default
49 /// Construct a strand for the specified executor.
55 is_convertible<Executor1, Executor>, in strand() argument
74 * to @c Executor.
95 * convertible to @c Executor.
[all …]
|
| /external/python/cpython3/Lib/test/test_concurrent_futures/ |
| D | test_process_pool.py | 12 from .executor import ExecutorTest, mul
37 futures = [self.executor.submit(time.sleep, 3)]
39 p = next(iter(self.executor._processes.values()))
44 self.assertRaises(BrokenProcessPool, self.executor.submit, pow, 2, 8)
48 list(self.executor.map(pow, range(40), range(40), chunksize=-1))
52 list(self.executor.map(pow, range(40), range(40), chunksize=6)),
55 list(self.executor.map(pow, range(40), range(40), chunksize=50)),
58 list(self.executor.map(pow, range(40), range(40), chunksize=40)),
69 future = self.executor.submit(self._test_traceback)
94 future = self.executor.submit(id, obj)
[all …]
|
| D | test_shutdown.py | 25 self.executor.shutdown()
27 self.executor.submit,
81 fs = [self.executor.submit(time.sleep, 0.1) for _ in range(50)]
82 self.executor.shutdown()
88 fs = [self.executor.submit(time.sleep, .1) for _ in range(50)]
89 self.executor.shutdown(cancel_futures=True)
147 executor = self.executor_type(max_workers=1, **kwargs)
148 executor.submit(int).result()
152 executor.submit(int).cancel()
153 executor.shutdown(wait=True)
[all …]
|
| D | test_deadlock.py | 96 def _fail_on_deadlock(self, executor): argument
98 # executor is in a deadlock state and forcefully clean all its
106 for p in executor._processes.values():
108 # This should be safe to call executor.shutdown here as all possible
110 executor.shutdown(wait=True)
112 self.fail(f"Executor deadlock:\n\n{tb}")
117 self.executor.shutdown(wait=True)
119 executor = self.executor_type(
121 res = executor.submit(func, *args)
134 # consider that the executor is in a deadlock state
[all …]
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | ExecutionListBenchmark.java | 38 import java.util.concurrent.Executor;
55 void add(Runnable runnable, Executor executor); in add() argument
70 public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
71 list.add(runnable, executor); in newExecutionList()
93 public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
94 list.add(runnable, executor); in newExecutionList()
116 public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
117 list.add(runnable, executor); in newExecutionList()
139 public void add(Runnable runnable, Executor executor) {
140 list.add(runnable, executor);
[all …]
|
| /external/guava/android/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | ExecutionListBenchmark.java | 38 import java.util.concurrent.Executor;
55 void add(Runnable runnable, Executor executor); in add() argument
70 public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
71 list.add(runnable, executor); in newExecutionList()
93 public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
94 list.add(runnable, executor); in newExecutionList()
116 public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
117 list.add(runnable, executor); in newExecutionList()
139 public void add(Runnable runnable, Executor executor) {
140 list.add(runnable, executor);
[all …]
|
| /external/robolectric/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowBluetoothLeBroadcast.java | 12 import java.util.concurrent.Executor;
23 private final Map<BluetoothLeBroadcast.Callback, Executor> mCallbackExecutorMap = new HashMap<>();
27 protected void registerCallback(Executor executor, BluetoothLeBroadcast.Callback callback) { in registerCallback() argument
28 Objects.requireNonNull(executor, "executor cannot be null"); in registerCallback()
34 mCallbackExecutorMap.put(callback, executor); in registerCallback()
99 public Map<BluetoothLeBroadcast.Callback, Executor> getCallbackExecutorMap() { in getCallbackExecutorMap()
105 int reason, Map<BluetoothLeBroadcast.Callback, Executor> callbackExecutorMap) { in sendOnBroadcastStartFailed()
106 for (Map.Entry<BluetoothLeBroadcast.Callback, Executor> entry : in sendOnBroadcastStartFailed()
109 Executor executor = entry.getValue(); in sendOnBroadcastStartFailed() local
110 executor.execute(() -> callback.onBroadcastStartFailed(reason)); in sendOnBroadcastStartFailed()
[all …]
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | SerializingExecutorTest.java | 29 import java.util.concurrent.Executor;
37 private SerializingExecutor executor = new SerializingExecutor(singleExecutor); field in SerializingExecutorTest
55 class CoyExecutor implements Executor { in resumable()
68 executor = new SerializingExecutor(new CoyExecutor()); in resumable()
70 executor.execute(new AddToRuns(1)); in resumable()
76 executor.execute(new AddToRuns(2)); in resumable()
84 executor.execute(new AddToRuns(1)); in serial()
89 executor.execute(new AddToRuns(2)); in serial()
97 executor.execute(new AddToRuns(1)); in parallel()
98 executor.execute(new AddToRuns(2)); in parallel()
[all …]
|
| D | ConnectivityStateManagerTest.java | 29 import java.util.concurrent.Executor;
45 private final FakeClock executor = new FakeClock(); field in ConnectivityStateManagerTest
67 }, executor.getScheduledExecutorService(), CONNECTING); in registerCallbackBeforeStateChanged()
69 assertEquals(0, executor.numPendingTasks()); in registerCallbackBeforeStateChanged()
71 // Make sure the callback is run in the executor in registerCallbackBeforeStateChanged()
73 assertEquals(1, executor.runDueTasks()); in registerCallbackBeforeStateChanged()
74 assertEquals(0, executor.numPendingTasks()); in registerCallbackBeforeStateChanged()
89 }, executor.getScheduledExecutorService(), IDLE); in registerCallbackAfterStateChanged()
91 // Make sure the callback is run in the executor in registerCallbackAfterStateChanged()
93 assertEquals(1, executor.runDueTasks()); in registerCallbackAfterStateChanged()
[all …]
|
| /external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/tracing/ |
| D | PropagatedFutures.java | 26 import java.util.concurrent.Executor;
40 Executor executor) { in transformAsync() argument
41 return Futures.transformAsync(input, function, executor); in transformAsync()
46 ListenableFuture<I> input, Function<? super I, ? extends O> function, Executor executor) { in transform() argument
47 return Futures.transform(input, function, executor); in transform()
51 ListenableFuture<V> future, FutureCallback<? super V> callback, Executor executor) { in addCallback() argument
52 Futures.addCallback(future, callback, executor); in addCallback()
59 Executor executor) { in catching() argument
60 return Futures.catching(input, exceptionType, fallback, executor); in catching()
67 Executor executor) { in catchingAsync() argument
[all …]
|
| /external/sdv/vsomeip/third_party/boost/asio/include/boost/asio/impl/ |
| D | use_awaitable.hpp | 27 template <typename Executor, typename T>
29 : public awaitable_thread<Executor>
33 typedef awaitable<T, Executor> awaitable_type;
36 awaitable_handler_base(awaitable<void, Executor> a, const Executor& ex) in awaitable_handler_base()
37 : awaitable_thread<Executor>(std::move(a), ex) in awaitable_handler_base()
42 explicit awaitable_handler_base(awaitable_thread<Executor>* h) in awaitable_handler_base()
43 : awaitable_thread<Executor>(std::move(*h)) in awaitable_handler_base()
48 awaitable_frame<T, Executor>* frame() noexcept in frame()
50 return static_cast<awaitable_frame<T, Executor>*>(this->top_of_stack_); in frame()
57 template <typename Executor>
[all …]
|
| D | co_spawn.hpp | 32 template <typename Executor, typename = void>
37 typename prefer_result<Executor,
42 co_spawn_work_guard(const Executor& ex) in co_spawn_work_guard()
58 template <typename Executor>
59 struct co_spawn_work_guard<Executor,
61 !execution::is_executor<Executor>::value
62 >::type> : executor_work_guard<Executor>
64 co_spawn_work_guard(const Executor& ex) in co_spawn_work_guard()
65 : executor_work_guard<Executor>(ex) in co_spawn_work_guard()
72 template <typename Executor>
[all …]
|
| D | executor.hpp | 2 // impl/executor.hpp
25 #include <boost/asio/executor.hpp>
35 // Default polymorphic executor implementation.
36 template <typename Executor, typename Allocator>
37 class executor::impl
38 : public executor::impl_base
43 static impl_base* create(const Executor& e, Allocator a = Allocator()) in create()
51 impl(const Executor& e, const Allocator& a) BOOST_ASIO_NOEXCEPT in impl()
108 return type_id<Executor>(); in target_type()
127 return executor_ == *static_cast<const Executor*>(e->target()); in equals()
[all …]
|
| D | connect.hpp | 106 template <typename Protocol, typename Executor, typename EndpointSequence>
107 typename Protocol::endpoint connect(basic_socket<Protocol, Executor>& s, in connect()
118 template <typename Protocol, typename Executor, typename EndpointSequence>
119 typename Protocol::endpoint connect(basic_socket<Protocol, Executor>& s, in connect()
130 template <typename Protocol, typename Executor, typename Iterator>
131 Iterator connect(basic_socket<Protocol, Executor>& s, Iterator begin, in connect()
140 template <typename Protocol, typename Executor, typename Iterator>
141 inline Iterator connect(basic_socket<Protocol, Executor>& s, in connect()
149 template <typename Protocol, typename Executor, typename Iterator>
150 Iterator connect(basic_socket<Protocol, Executor>& s, in connect()
[all …]
|
| /external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/extensions/cronet/src/main/java/com/google/android/exoplayer2/ext/cronet/ |
| D | CronetDataSourceFactory.java | 23 import java.util.concurrent.Executor;
39 private final Executor executor; field in CronetDataSourceFactory
56 * @param executor The {@link java.util.concurrent.Executor} that will perform the requests.
62 Executor executor, in CronetDataSourceFactory() argument
66 executor, in CronetDataSourceFactory()
84 * @param executor The {@link java.util.concurrent.Executor} that will perform the requests.
86 public CronetDataSourceFactory(CronetEngineWrapper cronetEngineWrapper, Executor executor) { in CronetDataSourceFactory() argument
87 this(cronetEngineWrapper, executor, /* userAgent= */ (String) null); in CronetDataSourceFactory()
100 * @param executor The {@link java.util.concurrent.Executor} that will perform the requests.
106 CronetEngineWrapper cronetEngineWrapper, Executor executor, @Nullable String userAgent) { in CronetDataSourceFactory() argument
[all …]
|
| /external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/extensions/cronet/src/main/java/com/google/android/exoplayer2/ext/cronet/ |
| D | CronetDataSourceFactory.java | 25 import java.util.concurrent.Executor;
43 private final Executor executor; field in CronetDataSourceFactory
60 * @param executor The {@link java.util.concurrent.Executor} that will perform the requests.
66 Executor executor, in CronetDataSourceFactory() argument
70 executor, in CronetDataSourceFactory()
88 * @param executor The {@link java.util.concurrent.Executor} that will perform the requests.
90 public CronetDataSourceFactory(CronetEngineWrapper cronetEngineWrapper, Executor executor) { in CronetDataSourceFactory() argument
91 this(cronetEngineWrapper, executor, /* userAgent= */ (String) null); in CronetDataSourceFactory()
104 * @param executor The {@link java.util.concurrent.Executor} that will perform the requests.
110 CronetEngineWrapper cronetEngineWrapper, Executor executor, @Nullable String userAgent) { in CronetDataSourceFactory() argument
[all …]
|
| /external/cronet/tot/net/proxy_resolution/ |
| D | multi_threaded_proxy_resolver.cc | 41 // An "executor" is a job-runner for PAC requests. It encapsulates a worker
44 class Executor : public base::RefCountedThreadSafe<Executor> { class
48 virtual void OnExecutorReady(Executor* executor) = 0;
55 // signal when the executor is ready to receive work by calling
58 Executor(Coordinator* coordinator, int thread_number);
60 // Submit a job to this executor.
63 // Callback for when a job has completed running on the executor's thread.
66 // Cleanup the executor. Cancels all outstanding work, and frees the thread
88 friend class base::RefCountedThreadSafe<Executor>;
89 ~Executor();
[all …]
|
| /external/cronet/stable/net/proxy_resolution/ |
| D | multi_threaded_proxy_resolver.cc | 41 // An "executor" is a job-runner for PAC requests. It encapsulates a worker
44 class Executor : public base::RefCountedThreadSafe<Executor> { class
48 virtual void OnExecutorReady(Executor* executor) = 0;
55 // signal when the executor is ready to receive work by calling
58 Executor(Coordinator* coordinator, int thread_number);
60 // Submit a job to this executor.
63 // Callback for when a job has completed running on the executor's thread.
66 // Cleanup the executor. Cancels all outstanding work, and frees the thread
88 friend class base::RefCountedThreadSafe<Executor>;
89 ~Executor();
[all …]
|
| /external/guava/android/guava/src/com/google/common/eventbus/ |
| D | AsyncEventBus.java | 17 import java.util.concurrent.Executor;
20 * An {@link EventBus} that takes the Executor of your choice and uses it to dispatch events,
30 * Creates a new AsyncEventBus that will use {@code executor} to dispatch events. Assigns {@code
34 * @param executor Executor to use to dispatch events. It is the caller's responsibility to shut
35 * down the executor after the last event has been posted to this event bus.
37 public AsyncEventBus(String identifier, Executor executor) { in AsyncEventBus() argument
38 super(identifier, executor, Dispatcher.legacyAsync(), LoggingHandler.INSTANCE); in AsyncEventBus()
42 * Creates a new AsyncEventBus that will use {@code executor} to dispatch events.
44 * @param executor Executor to use to dispatch events. It is the caller's responsibility to shut
45 * down the executor after the last event has been posted to this event bus.
[all …]
|
| /external/guava/guava/src/com/google/common/eventbus/ |
| D | AsyncEventBus.java | 17 import java.util.concurrent.Executor;
20 * An {@link EventBus} that takes the Executor of your choice and uses it to dispatch events,
30 * Creates a new AsyncEventBus that will use {@code executor} to dispatch events. Assigns {@code
34 * @param executor Executor to use to dispatch events. It is the caller's responsibility to shut
35 * down the executor after the last event has been posted to this event bus.
37 public AsyncEventBus(String identifier, Executor executor) { in AsyncEventBus() argument
38 super(identifier, executor, Dispatcher.legacyAsync(), LoggingHandler.INSTANCE); in AsyncEventBus()
42 * Creates a new AsyncEventBus that will use {@code executor} to dispatch events.
44 * @param executor Executor to use to dispatch events. It is the caller's responsibility to shut
45 * down the executor after the last event has been posted to this event bus.
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Executors.kt | 10 * [CoroutineDispatcher] that has underlying [Executor] for dispatching tasks.
14 * asynchronous API that requires an instance of the [Executor].
24 * Underlying executor of current [CoroutineDispatcher].
26 public abstract val executor: Executor constant in kotlinx.coroutines.ExecutorCoroutineDispatcher
29 * Closes this coroutine dispatcher and shuts down its executor.
46 * on this executor using [schedule][ScheduledExecutorService.schedule] method. If the corresponding in close()
53 * If the executor service is neither of this types, the separate internal thread will be used to in close()
55 * on top of the given executor. in close()
58 * If the underlying executor throws [RejectedExecutionException] on in close()
60 …* resulting dispatcher, on underlying executor [shutdown][ExecutorService.shutdown], or when it us… in close()
[all …]
|
| /external/executorch/kernels/optimized/ |
| D | optimized.yaml | 8 kernel_name: torch::executor::opt_log_softmax_out
13 kernel_name: torch::executor::opt_add_out
18 kernel_name: torch::executor::opt_add_scalar_out
23 kernel_name: torch::executor::opt_bmm_out
28 kernel_name: torch::executor::opt_div_out
33 kernel_name: torch::executor::opt_div_scalar_out
38 kernel_name: torch::executor::opt_exp_out
43 kernel_name: torch::executor::opt_sigmoid_out
48 kernel_name: torch::executor::opt_gelu_out
53 kernel_name: torch::executor::opt_le_scalar_out
[all …]
|
| /external/executorch/runtime/core/exec_aten/ |
| D | exec_aten.h | 33 #else // use executor
98 #else // Use executor types
100 using Tensor = torch::executor::Tensor;
101 using TensorImpl = torch::executor::TensorImpl;
102 using string_view = torch::executor::string_view;
104 using ArrayRef = torch::executor::ArrayRef<T>;
106 using optional = torch::executor::optional<T>;
107 using nullopt_t = torch::executor::nullopt_t;
110 using ScalarType = torch::executor::ScalarType;
112 using Scalar = torch::executor::Scalar;
[all …]
|