| /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)
228 futures = [self.executor.submit(get_init_status)
256 future = self.executor.submit(get_init_status)
265 while not self.executor._broken:
271 self.executor.submit(get_init_status)
300 self.executor.shutdown()
[all …]
|
| /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/boost/libs/asio/include/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/boost/libs/asio/test/execution/ |
| D | scheduler.cpp | 27 struct executor struct
29 executor() in executor() function
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() function
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() argument
47 executor(executor&&) BOOST_ASIO_NOEXCEPT in executor() argument
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() argument
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() function
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() argument
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 | 174 &boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
179 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
184 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
189 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
194 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
199 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
204 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
209 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
214 boost::asio::query(pool.executor(), in thread_pool_executor_query_test()
219 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 | 37 class executor::impl
38 : public executor::impl_base
161 class executor::impl<system_executor, Allocator>
162 : public executor::impl_base
243 executor::executor(Executor e) in executor() function in boost::asio::executor
249 executor::executor(allocator_arg_t, const Allocator& a, Executor e) in executor() function in boost::asio::executor
255 void executor::dispatch(BOOST_ASIO_MOVE_ARG(Function) f, in dispatch()
266 void executor::post(BOOST_ASIO_MOVE_ARG(Function) f, in post()
273 void executor::defer(BOOST_ASIO_MOVE_ARG(Function) f, in defer()
280 Executor* executor::target() BOOST_ASIO_NOEXCEPT in target()
[all …]
|
| /third_party/python/Lib/concurrent/futures/ |
| D | thread.py | 75 executor = executor_reference()
76 if executor is not None:
77 executor._initializer_failed()
88 executor = executor_reference()
89 if executor is not None:
90 executor._idle_semaphore.release()
91 del executor
94 executor = executor_reference()
99 if _shutdown or executor is None or executor._shutdown:
102 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/include/boost/asio/impl/ |
| D | executor.hpp | 37 class executor::impl
38 : public executor::impl_base
161 class executor::impl<system_executor, Allocator>
162 : public executor::impl_base
243 executor::executor(Executor e) in executor() function in boost::asio::executor
249 executor::executor(allocator_arg_t, const Allocator& a, Executor e) in executor() function in boost::asio::executor
255 void executor::dispatch(BOOST_ASIO_MOVE_ARG(Function) f, in dispatch()
266 void executor::post(BOOST_ASIO_MOVE_ARG(Function) f, in post()
273 void executor::defer(BOOST_ASIO_MOVE_ARG(Function) f, in defer()
280 Executor* executor::target() BOOST_ASIO_NOEXCEPT in target()
[all …]
|
| /third_party/vk-gl-cts/executor/ |
| D | xeBatchExecutor.cpp | 352 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueStateChanged() local
353 CallWriter writer (&executor->m_dispatcher, BatchExecutor::dispatchStateChanged); in enqueueStateChanged()
355 writer << executor in enqueueStateChanged()
364 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueTestLogData() local
365 CallWriter writer (&executor->m_dispatcher, BatchExecutor::dispatchTestLogData); in enqueueTestLogData()
367 writer << executor in enqueueTestLogData()
376 BatchExecutor* executor = static_cast<BatchExecutor*>(userPtr); in enqueueInfoLogData() local
377 CallWriter writer (&executor->m_dispatcher, BatchExecutor::dispatchInfoLogData); in enqueueInfoLogData()
379 writer << executor in enqueueInfoLogData()
388 BatchExecutor* executor = DE_NULL; in dispatchStateChanged() local
[all …]
|
| /third_party/mindspore/mindspore/ccsrc/frontend/parallel/ |
| D | group_manager.cc | 81 auto executor = session::ExecutorManager::Instance().GetExecutor(device_name, device_id); in CreateGroupByExecutor() local
82 MS_EXCEPTION_IF_NULL(executor); in CreateGroupByExecutor()
83 return executor->CreateCommGroup(group_name, ranks); in CreateGroupByExecutor()
94 auto executor = session::ExecutorManager::Instance().GetExecutor(device_name, device_id); in DestroyGroupByExecutor() local
95 MS_EXCEPTION_IF_NULL(executor); in DestroyGroupByExecutor()
96 return executor->DestroyCommGroup(group_name); in DestroyGroupByExecutor()
106 auto executor = session::ExecutorManager::Instance().GetExecutor(device_name, device_id); in CreateGroups() local
107 MS_EXCEPTION_IF_NULL(executor); in CreateGroups()
115 ret = executor->CreateCommGroup(group.first, group.second); in CreateGroups()
130 auto executor = parallel::ExecutorManager::Instance().GetExecutor(device_name, device_id); in CreateGroupByExecutor() local
[all …]
|
| /third_party/mindspore/mindspore/ccsrc/backend/session/ |
| D | executor_manager.cc | 26 auto executor = std::make_shared<Executor>(device_name, device_id); in GetExecutor() local
27 executors_[device_key] = executor; in GetExecutor()
28 return executor; in GetExecutor()
33 auto &executor = item.second; in OnEvent() local
34 if (executor != nullptr) { in OnEvent()
35 executor->OnEvent(event); in OnEvent()
|
| /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/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/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/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()
|