| /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/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() argument
65 public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
66 list.add(runnable, executor); in newExecutionList()
88 public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
89 list.add(runnable, executor); in newExecutionList()
111 public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
112 list.add(runnable, executor); in newExecutionList()
134 public void add(Runnable runnable, Executor executor) {
135 list.add(runnable, executor);
[all …]
|
| D | MoreExecutorsDirectExecutorBenchmark.java | 30 import java.util.concurrent.Executor;
42 Executor executor() { in executor() method
46 EXECUTOR { enumConstant
48 Executor executor() { in executor() method
53 abstract Executor executor(); in executor() method in MoreExecutorsDirectExecutorBenchmark.Impl
57 Executor executor; field in MoreExecutorsDirectExecutorBenchmark
74 executor = impl.executor(); in before()
82 executor.execute(localRunnable); in before()
101 return executor; in measureSize()
106 final Executor executor = this.executor; in timeUncontendedExecute() local
[all …]
|
| /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() argument
65 public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
66 list.add(runnable, executor); in newExecutionList()
88 public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
89 list.add(runnable, executor); in newExecutionList()
111 public void add(Runnable runnable, Executor executor) { in newExecutionList() argument
112 list.add(runnable, executor); in newExecutionList()
134 public void add(Runnable runnable, Executor executor) {
135 list.add(runnable, executor);
[all …]
|
| D | MoreExecutorsDirectExecutorBenchmark.java | 30 import java.util.concurrent.Executor;
42 Executor executor() { in executor() method
46 EXECUTOR { enumConstant
48 Executor executor() { in executor() method
53 abstract Executor executor(); in executor() method in MoreExecutorsDirectExecutorBenchmark.Impl
57 Executor executor; field in MoreExecutorsDirectExecutorBenchmark
74 executor = impl.executor(); in before()
82 executor.execute(localRunnable); in before()
101 return executor; in measureSize()
106 final Executor executor = this.executor; in timeUncontendedExecute() local
[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/python/cpython3/Lib/test/ |
| D | test_concurrent_futures.py | 126 self.executor = self.executor_type(
131 self.executor = self.executor_type(
136 self.executor.shutdown(wait=True)
137 self.executor = None
225 futures = [self.executor.submit(get_init_status)
253 future = self.executor.submit(get_init_status)
255 # Perhaps the executor is already broken
260 # At some point, the executor should break
262 while not self.executor._broken:
264 self.fail("executor not broken after 5 s.")
[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/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/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/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/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/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/kotlinx.coroutines/kotlinx-coroutines-core/jvm/src/ |
| D | Executors.kt | 14 * [CoroutineDispatcher] that has underlying [Executor] for dispatching tasks.
18 * asynchronous API that requires an instance of the [Executor].
28 * Underlying executor of current [CoroutineDispatcher].
30 public abstract val executor: Executor constant in kotlinx.coroutines.ExecutorCoroutineDispatcher
33 * Closes this coroutine dispatcher and shuts down its executor.
50 * on this executor using [schedule][ScheduledExecutorService.schedule] method. If the corresponding in close()
57 * If the executor service is neither of this types, the separate internal thread will be used to in close()
59 * on top of the given executor. in close()
62 * If the underlying executor throws [RejectedExecutionException] on in close()
64 …* resulting dispatcher, on underlying executor [shutdown][ExecutorService.shutdown], or when it us… in close()
[all …]
|
| /external/grpc-grpc-java/core/src/main/java/io/grpc/internal/ |
| D | SerializingExecutor.java | 24 import java.util.concurrent.Executor;
31 * Executor ensuring that all {@link Runnable} tasks submitted are executed in order
32 * using the provided {@link Executor}, and serially such that no two will ever be
36 public final class SerializingExecutor implements Executor, Runnable {
61 /** Underlying executor that all submitted Runnable objects are run on. */
62 private Executor executor; field in SerializingExecutor
70 * Creates a SerializingExecutor, running tasks using {@code executor}.
72 * @param executor Executor in which tasks should be run. Must not be null.
74 public SerializingExecutor(Executor executor) { in SerializingExecutor() argument
75 Preconditions.checkNotNull(executor, "'executor' must not be null."); in SerializingExecutor()
[all …]
|
| /external/sdv/vsomeip/third_party/boost/thread/include/boost/thread/executors/ |
| D | scheduler.hpp | 29 …/// Wraps the reference to an executor and a function to make a work that submit the function usin…
30 template <class Executor, class Function>
34 resubmitter(Executor& ex, Function funct) : in resubmitter()
45 Executor& ex;
50 template <class Executor, class Function>
51 resubmitter<Executor, typename decay<Function>::type>
52 resubmit(Executor& ex, BOOST_THREAD_FWD_REF(Function) funct) { in resubmit()
53 return resubmitter<Executor, typename decay<Function>::type >(ex, boost::move(funct)); in resubmit()
56 /// Wraps references to a @c Scheduler and an @c Executor providing an @c Executor that
57 …/// resubmit the function using the referenced Executor at a given @c time_point known at construc…
[all …]
|
| /external/sdv/vsomeip/third_party/boost/thread/doc/ |
| D | async_executors.qbk | 15 ….Thread differs from N3785 mainly in the an Executor doesn't needs to inherit from an abstract cla…
22 …executor objects. This allows programs to start executors when necessary, switch from one executor…
34 …executor, in which one thread donates itself to the executor to execute all queued work. This is r…
35 …executor, where a GUI framework can expose an executor interface to allow other threads to queue u…
37 …executor, but always uses the caller’s thread to execute. This allows parallel execution of works,…
39 …executor (e.g. the thread pool) to have more precise control of where the work is executed due to …
115 …executor class we make executor concepts. We believe that this is the good direction as a static p…
119 …Executor is an object that schedules the closures that have been submitted to it, usually asynchro…
121 * Thread pools are well know models of the Executor concept, and this library does indeed include a…
123 …executor to use is explicit. This is important for reasons described in the Motivation section. In…
[all …]
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | ExecutionList.java | 22 import java.util.concurrent.Executor;
28 * instance contains a list of listeners, each with an associated {@code Executor}, and guarantees
34 * <p>Exceptions thrown by a listener will be propagated up to the executor. Any exception thrown
35 * during {@code Executor.execute} (e.g., a {@code RejectedExecutionException} or an exception
50 * The runnable, executor pairs to execute. This acts as a stack threaded through the {@link
64 * Adds the {@code Runnable} and accompanying {@code Executor} to the list of listeners to
67 * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See
71 public void add(Runnable runnable, Executor executor) { in add() argument
72 // Fail fast on a null. We throw NPE here because the contract of Executor states that it throws in add()
75 checkNotNull(executor, "Executor was null."); in add()
[all …]
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ExecutionList.java | 22 import java.util.concurrent.Executor;
28 * instance contains a list of listeners, each with an associated {@code Executor}, and guarantees
34 * <p>Exceptions thrown by a listener will be propagated up to the executor. Any exception thrown
35 * during {@code Executor.execute} (e.g., a {@code RejectedExecutionException} or an exception
50 * The runnable, executor pairs to execute. This acts as a stack threaded through the {@link
64 * Adds the {@code Runnable} and accompanying {@code Executor} to the list of listeners to
67 * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See
71 public void add(Runnable runnable, Executor executor) { in add() argument
72 // Fail fast on a null. We throw NPE here because the contract of Executor states that it throws in add()
75 checkNotNull(executor, "Executor was null."); in add()
[all …]
|