| /third_party/boost/boost/asio/ |
| D | executor.hpp | 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
80 executor(Executor e);
85 executor(allocator_arg_t, const Allocator& a, Executor e);
88 ~executor() in ~executor()
94 executor& operator=(const executor& other) BOOST_ASIO_NOEXCEPT in operator =()
103 executor& operator=(executor&& other) BOOST_ASIO_NOEXCEPT in operator =()
[all …]
|
| /third_party/python/Lib/test/ |
| D | test_concurrent_futures.py | 120 self.executor = self.executor_type(
125 self.executor = self.executor_type(
131 self.executor.shutdown(wait=True)
132 self.executor = None
147 futures = [self.executor.submit(time.sleep, 0.1)
213 futures = [self.executor.submit(get_init_status)
241 future = self.executor.submit(get_init_status)
250 while not self.executor._broken:
256 self.executor.submit(get_init_status)
285 self.executor.shutdown()
[all …]
|
| /third_party/boost/libs/asio/test/execution/ |
| D | scheduler.cpp | 27 struct executor struct
29 executor() in executor() argument
33 executor(const executor&) BOOST_ASIO_NOEXCEPT in executor() function
38 executor(executor&&) BOOST_ASIO_NOEXCEPT in executor() function
49 bool operator==(const executor&) const BOOST_ASIO_NOEXCEPT in operator ==() argument
54 bool operator!=(const executor&) const BOOST_ASIO_NOEXCEPT in operator !=() argument
67 struct execute_member<executor, F>
78 struct equality_comparable<executor>
94 BOOST_ASIO_CHECK(exec::is_scheduler<executor>::value); in test_is_scheduler()
|
| D | executor.cpp | 25 struct executor struct
27 executor() in executor() function
31 executor(const executor&) BOOST_ASIO_NOEXCEPT in executor() function
36 executor(executor&&) BOOST_ASIO_NOEXCEPT in executor() argument
47 bool operator==(const executor&) const BOOST_ASIO_NOEXCEPT in operator ==() argument
52 bool operator!=(const executor&) const BOOST_ASIO_NOEXCEPT in operator !=() argument
65 struct execute_member<executor, F>
76 struct equality_comparable<executor>
102 executor in is_executor_test()
122 executor, in is_executor_of_test()
[all …]
|
| D | sender.cpp | 36 struct executor struct
38 executor() in executor() argument
42 executor(const executor&) BOOST_ASIO_NOEXCEPT in executor() function
47 executor(executor&&) BOOST_ASIO_NOEXCEPT in executor() function
58 bool operator==(const executor&) const BOOST_ASIO_NOEXCEPT in operator ==() argument
63 bool operator!=(const executor&) const BOOST_ASIO_NOEXCEPT in operator !=() argument
76 struct execute_member<executor, F>
87 struct equality_comparable<executor>
198 executor s3; in test_sender_traits()
212 BOOST_ASIO_CHECK(exec::is_sender<executor>::value); in test_is_sender()
[all …]
|
| D | bulk_execute.cpp | 160 struct executor struct
162 executor() in executor() argument
166 executor(const executor&) BOOST_ASIO_NOEXCEPT in executor() argument
171 executor(executor&&) BOOST_ASIO_NOEXCEPT in executor() function
183 bool operator==(const executor&) const BOOST_ASIO_NOEXCEPT in operator ==() argument
188 bool operator!=(const executor&) const BOOST_ASIO_NOEXCEPT in operator !=() argument
201 struct execute_member<executor, F>
212 struct equality_comparable<executor>
252 executor&, exec::invocable_archetype, std::size_t>::value; in test_can_bulk_execute()
256 const executor&, exec::invocable_archetype, std::size_t>::value; in test_can_bulk_execute()
[all …]
|
| D | connect.cpp | 287 struct executor struct
289 executor() in executor() argument
293 executor(const executor&) BOOST_ASIO_NOEXCEPT in executor() argument
298 executor(executor&&) BOOST_ASIO_NOEXCEPT in executor() function
309 bool operator==(const executor&) const BOOST_ASIO_NOEXCEPT in operator ==() argument
314 bool operator!=(const executor&) const BOOST_ASIO_NOEXCEPT in operator !=() argument
327 struct execute_member<executor, F>
338 struct equality_comparable<executor>
409 executor&, receiver>::value; in test_can_connect()
413 const executor&, receiver>::value; in test_can_connect()
[all …]
|
| D | schedule.cpp | 227 struct executor struct
229 executor() in executor() function
233 executor(const executor&) BOOST_ASIO_NOEXCEPT in executor() argument
238 executor(executor&&) BOOST_ASIO_NOEXCEPT in executor() function
250 bool operator==(const executor&) const BOOST_ASIO_NOEXCEPT in operator ==() argument
255 bool operator!=(const executor&) const BOOST_ASIO_NOEXCEPT in operator !=() argument
268 struct execute_member<executor, F>
279 struct equality_comparable<executor>
334 executor&>::value; in test_can_schedule()
338 const executor&>::value; in test_can_schedule()
[all …]
|
| D | submit.cpp | 364 struct executor struct
366 executor() in executor() function
370 executor(const executor&) BOOST_ASIO_NOEXCEPT in executor() argument
375 executor(executor&&) BOOST_ASIO_NOEXCEPT in executor() function
387 bool operator==(const executor&) const BOOST_ASIO_NOEXCEPT in operator ==() argument
392 bool operator!=(const executor&) const BOOST_ASIO_NOEXCEPT in operator !=() argument
405 struct execute_member<executor, F>
416 struct equality_comparable<executor>
487 executor&, receiver>::value; in test_can_submit()
491 const executor&, receiver>::value; in test_can_submit()
[all …]
|
| /third_party/boost/libs/asio/test/ |
| D | thread_pool.cpp | 166 &boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
171 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
176 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
181 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
186 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
191 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
196 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
201 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
206 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
211 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
[all …]
|
| /third_party/boost/libs/thread/test/ |
| D | test_11256.cpp | 20 auto stepOne(boost::basic_thread_pool &executor) in stepOne() argument
23 auto wrappedFuture = sendFuture.then(executor, [](auto f) mutable { in stepOne()
30 auto stepTwo(boost::basic_thread_pool &executor) in stepTwo() argument
32 auto future = stepOne(executor); in stepTwo()
33 return future.then(executor, [](auto f) { in stepTwo()
40 boost::basic_thread_pool executor{1}; in main() local
41 stepTwo(executor).get(); in main()
|
| /third_party/boost/boost/asio/impl/ |
| D | executor.hpp | 38 class executor::impl
39 : public executor::impl_base
162 class executor::impl<system_executor, Allocator>
163 : public executor::impl_base
244 executor::executor(Executor e) in executor() function in boost::asio::executor
250 executor::executor(allocator_arg_t, const Allocator& a, Executor e) in executor() function in boost::asio::executor
256 void executor::dispatch(BOOST_ASIO_MOVE_ARG(Function) f, in dispatch()
267 void executor::post(BOOST_ASIO_MOVE_ARG(Function) f, in post()
274 void executor::defer(BOOST_ASIO_MOVE_ARG(Function) f, in defer()
281 Executor* executor::target() BOOST_ASIO_NOEXCEPT in target()
[all …]
|
| /third_party/python/Lib/concurrent/futures/ |
| D | thread.py | 69 executor = executor_reference()
70 if executor is not None:
71 executor._initializer_failed()
82 executor = executor_reference()
83 if executor is not None:
84 executor._idle_semaphore.release()
85 del executor
88 executor = executor_reference()
93 if _shutdown or executor is None or executor._shutdown:
96 if executor is not None:
[all …]
|
| D | process.py | 268 def __init__(self, executor): argument
273 self.thread_wakeup = executor._executor_manager_thread_wakeup
274 self.shutdown_lock = executor._shutdown_lock
290 self.executor_reference = weakref.ref(executor, weakref_cb)
293 self.processes = executor._processes
297 self.call_queue = executor._call_queue
300 self.result_queue = executor._result_queue
303 self.work_ids_queue = executor._work_ids
307 self.pending_work_items = executor._pending_work_items
329 executor = self.executor_reference()
[all …]
|
| /third_party/boost/libs/asio/doc/ |
| D | std_executors.qbk | 14 Just as with executors under the Networking TS model, a standard executor
39 implementation determines at compile time which model a particular executor
40 meets; the proposed standard executor model is used in preference if both are
49 default runtime-polymorphic executor for all I/O objects. This type alias
55 wrapper, [link boost_asio.reference.executor `executor`]. If required for backward
57 the `any_io_executor` type alias to instead point to the `executor` polymorphic
62 Standard executor properties make what were previously hard requirements on an
63 executor (such as work counting, or the ability to distinguish between `post`,
65 minimal requirements for an I/O executor are:
68 `executor`] concept.
[all …]
|
| /third_party/boost/boost/thread/executors/ |
| D | executor.hpp | 25 class executor class
32 BOOST_THREAD_NO_COPYABLE(executor)
33 executor() {} in executor() function in boost::executors::executor
42 virtual ~executor() {} in ~executor()
144 using executors::executor;
|
| /third_party/boost/libs/thread/doc/ |
| D | async_executors.qbk | 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…
123 …executor to use is explicit. This is important for reasons described in the Motivation section. In…
125 * Even if there could be a strong value in having a default executor, that can be used when detaile…
127 …mic polymorphism interface has the advantage to been able to change the executor a function is usi…
129 …ually, an executor puts closures on a queue and at some point executes them. The queue is always u…
[all …]
|
| /third_party/boost/libs/asio/doc/requirements/ |
| D | Executor.qbk | 12 Let `executor-of-impl` be the exposition-only concept
15 concept executor-of-impl =
26 Then the `executor` and `executor_of` concepts are defined as follows:
29 concept executor =
30 executor-of-impl<E, execution::invocable_archetype>;
34 executor<E> &&
35 executor-of-impl<E, F>;
37 Neither an executor's equality comparison nor `swap` operation shall exit via
40 None of an executor type's copy constructor, destructor, equality comparison,
45 For any two (possibly const) values `x1` and `x2` of some executor type `X`,
[all …]
|
| /third_party/boost/boost/process/detail/windows/ |
| D | executor.hpp | 112 class executor : public startup_info_impl<Char> class
129 executor & exec;
130 on_setup_t(executor & exec) : exec(exec) {}; in on_setup_t()
141 executor & exec;
143 on_error_t(executor & exec, const std::error_code & error) : exec(exec), error(error) {}; in on_error_t()
153 executor & exec;
154 on_success_t(executor & exec) : exec(exec) {}; in on_success_t()
172 executor(Sequence & seq) : seq(seq) in executor() function in boost::process::detail::windows::executor
251 executor<Char, Tup> make_executor(Tup & tup) in make_executor()
253 return executor<Char, Tup>(tup); in make_executor()
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/invocation/ |
| D | prioritised_handlers.cpp | 36 class executor class in handler_priority_queue
39 executor(handler_priority_queue& q, int p) in executor() function in handler_priority_queue::executor
70 bool operator==(const executor& other) const in operator ==()
75 bool operator!=(const executor& other) const in operator !=()
86 boost::asio::executor_binder<Handler, executor>
89 return boost::asio::bind_executor(executor(*this, priority), handler); in wrap()
|
| /third_party/boost/libs/asio/example/cpp03/invocation/ |
| D | prioritised_handlers.cpp | 36 class executor class in handler_priority_queue
39 executor(handler_priority_queue& q, int p) in executor() function in handler_priority_queue::executor
70 bool operator==(const executor& other) const in operator ==()
75 bool operator!=(const executor& other) const in operator !=()
86 boost::asio::executor_binder<Handler, executor>
89 return boost::asio::bind_executor(executor(*this, priority), handler); in wrap()
|
| /third_party/boost/libs/asio/example/cpp11/invocation/ |
| D | prioritised_handlers.cpp | 40 class executor class in handler_priority_queue
43 executor(handler_priority_queue& q, int p) in executor() function in handler_priority_queue::executor
74 bool operator==(const executor& other) const noexcept in operator ==()
79 bool operator!=(const executor& other) const noexcept in operator !=()
90 boost::asio::executor_binder<Handler, executor>
94 executor(*this, priority), std::move(handler)); in wrap()
|
| /third_party/boost/doc/html/boost_asio/example/cpp11/invocation/ |
| D | prioritised_handlers.cpp | 40 class executor class in handler_priority_queue
43 executor(handler_priority_queue& q, int p) in executor() function in handler_priority_queue::executor
74 bool operator==(const executor& other) const noexcept in operator ==()
79 bool operator!=(const executor& other) const noexcept in operator !=()
90 boost::asio::executor_binder<Handler, executor>
94 executor(*this, priority), std::move(handler)); in wrap()
|
| /third_party/boost/libs/beast/example/websocket/client/async-ssl-system-executor/ |
| D | CMakeLists.txt | 13 GroupSources(example/websocket/client/async-ssl-system-executor "/")
15 add_executable (websocket-client-async-ssl-system-executor
22 …set_property(TARGET websocket-client-async-ssl-system-executor PROPERTY FOLDER "example-websocket-…
24 target_link_libraries (websocket-client-async-ssl-system-executor
|
| /third_party/boost/libs/beast/example/http/client/async-ssl-system-executor/ |
| D | CMakeLists.txt | 13 GroupSources(example/http/client/async-ssl-system-executor "/")
15 add_executable (http-client-async-ssl-system-executor
22 set_property(TARGET http-client-async-ssl-system-executor PROPERTY FOLDER "example-http-client")
24 target_link_libraries (http-client-async-ssl-system-executor
|