| /third_party/grpc/src/core/lib/iomgr/ |
| D | executor.cc | 19 #include "src/core/lib/iomgr/executor.h"
44 Executor* executors[static_cast<size_t>(ExecutorType::NUM_EXECUTORS)];
76 Executor::Executor(const char* name) : name_(name) { in Executor() function in grpc_core::Executor
82 void Executor::Init() { SetThreading(true); } in Init()
84 size_t Executor::RunClosures(const char* executor_name, in RunClosures()
88 // In the executor, the ExecCtx for the thread is declared in the executor in RunClosures()
94 // the executor's closure list (which were explicitly scheduled onto the in RunClosures()
95 // executor). in RunClosures()
103 GRPC_TRACE_LOG(executor, INFO) in RunClosures()
104 << "EXECUTOR (" << executor_name << ") run " << c << " [created by " in RunClosures()
[all …]
|
| D | executor.h | 55 class Executor {
57 explicit Executor(const char* executor_name);
61 /// Is the executor multi-threaded?
68 /// Shutdown the executor, running all pending work as part of the call
71 /// Enqueue the closure onto the executor. is_short is true if the closure is
76 // default executor and the resolver executor.
78 // Some of the functions below operate on the DEFAULT executor only while some
99 // Return if a given executor is running in threaded mode (i.e if
100 // SetThreading(true) was called previously on that executor)
103 // Return if the DEFAULT executor is threaded
|
| /third_party/python/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 …]
|
| /third_party/mindspore/mindspore-src/source/mindspore/lite/src/extendrt/graph_runtime/ |
| D | default_graph_runtime.cc | 22 #include "executor/sub_graph_kernel.h"
36 auto executor = SelectExecutor(); in Prepare() local
37 if (executor == nullptr) { in Prepare()
38 MS_LOG(ERROR) << "Select executor is nullptr."; in Prepare()
42 MS_LOG(DEBUG) << "Prepare executor begin"; in Prepare()
43 auto status = executor->Prepare(); in Prepare()
45 MS_LOG(ERROR) << "Prepare executor failed executor: " << executor->Name(); in Prepare()
48 MS_LOG(DEBUG) << "Prepare executor end"; in Prepare()
62 auto executor = SelectExecutor(); in Execute() local
63 if (executor == nullptr) { in Execute()
[all …]
|
| /third_party/mindspore/mindspore-src/source/tests/ut/cpp/pynative/ |
| D | op_executor_test.cc | 44 const auto &executor = runtime::OpExecutor::GetInstance(); in TEST_F() local
48 ASSERT_EQ(executor.NeedSync(), false); in TEST_F()
50 ASSERT_EQ(executor.NeedSync(), true); in TEST_F()
54 ASSERT_EQ(executor.NeedSync(), true); in TEST_F()
56 ASSERT_EQ(executor.NeedSync(), true); in TEST_F()
63 auto &executor = runtime::OpExecutor::GetInstance(); in TEST_F() local
65 executor.RegisterForwardCallback([&x]() { x += 1; }); in TEST_F()
66 executor.WaitAll(); in TEST_F()
69 executor.WaitAll(); in TEST_F()
72 executor.RegisterForwardCallback([]() {}); in TEST_F()
[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()
97 # - The executor that owns the worker has been collected OR
98 # - The executor that owns the worker has been shutdown.
[all …]
|
| D | process.py | 18 | Executor | | Thread | | |
27 Executor.submit() called:
280 executor: A reference to the ProcessPoolExecutor that owns
283 the executor.
286 def __init__(self, executor): argument
287 # Store references to necessary internals of the executor.
291 self.thread_wakeup = executor._executor_manager_thread_wakeup
292 self.shutdown_lock = executor._shutdown_lock
297 # When the executor gets garbage collected, the weakref callback
303 mp.util.debug('Executor collected: triggering callback for'
[all …]
|
| /third_party/mindspore/mindspore-src/source/mindspore/lite/src/executor/ |
| D | CMakeLists.txt | 28 ${LITE_DIR}/src/litert/executor.cc
33 ${LITE_DIR}/src/executor/kernel_exec.cc
35 ${LITE_DIR}/src/executor/sub_graph_kernel.cc
233 add_library(lite-unified-executor SHARED $<TARGET_OBJECTS:unified_runtime_lite_src_mid>)
235 target_link_libraries(lite-unified-executor lite_src_common_mid)
236 add_dependencies(lite-unified-executor mindspore_converter)
237 target_link_libraries(lite-unified-executor mindspore_converter)
240 set_target_properties(lite-unified-executor PROPERTIES PREFIX lib)
241 set_target_properties(lite-unified-executor PROPERTIES IMPORT_PREFIX lib)
242 set_target_properties(lite-unified-executor PROPERTIES IMPORT_SUFFIX .dll.lib)
[all …]
|
| /third_party/python/Doc/library/ |
| D | concurrent.futures.rst | 20 defined by the abstract :class:`Executor` class.
24 Executor Objects
27 .. class:: Executor
38 with ThreadPoolExecutor(max_workers=1) as executor:
39 future = executor.submit(pow, 323, 1235)
53 after *timeout* seconds from the original call to :meth:`Executor.map`.
73 Signal the executor that it should free any resources that it is using
75 :meth:`Executor.submit` and :meth:`Executor.map` made after shutdown will
80 executor have been freed. If *wait* is ``False`` then this method will
81 return immediately and the resources associated with the executor will be
[all …]
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/backend/common/session/ |
| D | executor_manager.cc | 24 std::shared_ptr<Executor> ExecutorManager::GetExecutor(const std::string &device_name, uint32_t dev… in GetExecutor()
30 auto executor = std::make_shared<Executor>(device_name, device_id); in GetExecutor() local
31 executors_[device_key] = executor; in GetExecutor()
32 return executor; in GetExecutor()
37 auto &executor = item.second; in OnEvent() local
38 if (executor != nullptr) { in OnEvent()
39 executor->OnEvent(event); in OnEvent()
|
| D | executor.cc | 16 #include "backend/common/session/executor.h"
104 Executor::~Executor() { in ~Executor()
108 MS_LOG(ERROR) << "Executor call destructor failed: " << e.what(); in ~Executor()
110 MS_LOG(ERROR) << "Executor call destructor failed."; in ~Executor()
114 void Executor::WorkerJoin() { in WorkerJoin()
127 void Executor::WorkerLoop() { in WorkerLoop()
170 std::vector<std::shared_ptr<RunGraphTask>> Executor::GetReadyTasksFromPendingList() { in GetReadyTasksFromPendingList()
185 void Executor::OnEvent(const ExecutorEvent &event) { in OnEvent()
195 void Executor::OnClear() { in OnClear()
203 void Executor::OnException() { in OnException()
[all …]
|
| D | executor_manager.h | 22 #include "backend/common/session/executor.h"
26 class Executor; variable
30 std::shared_ptr<Executor> GetExecutor(const std::string &device_name, uint32_t device_id);
35 auto &executor = item.second; in ClearDoneTasks() local
36 if (executor != nullptr) { in ClearDoneTasks()
37 executor->ClearDoneTasks(); in ClearDoneTasks()
47 std::map<std::string, std::shared_ptr<Executor>> executors_;
|
| /third_party/mindspore/mindspore-src/source/mindspore/lite/src/extendrt/mock/ |
| D | executor.cc | 16 #include "backend/common/session/executor.h"
156 Executor::Executor(const std::string &device_name, uint32_t device_id) { in Executor() function in mindspore::session::Executor
159 worker_ = std::make_shared<std::thread>(&Executor::WorkerLoop, this); in Executor()
162 Executor::~Executor() { in ~Executor()
166 MS_LOG(ERROR) << "Executor call destructor failed: " << e.what(); in ~Executor()
168 MS_LOG(ERROR) << "Executor call destructor failed."; in ~Executor()
172 void Executor::WorkerJoin() { in WorkerJoin()
185 void Executor::WorkerLoop() { in WorkerLoop()
228 std::vector<std::shared_ptr<RunGraphTask>> Executor::GetReadyTasksFromPendingList() { in GetReadyTasksFromPendingList()
243 void Executor::OnEvent(const ExecutorEvent &event) { in OnEvent()
[all …]
|
| /third_party/mindspore/mindspore-src/source/mindspore/lite/src/extendrt/ |
| D | executor.cc | 16 #include "backend/common/session/executor.h"
156 Executor::Executor(const std::string &device_name, uint32_t device_id) { in Executor() function in mindspore::session::Executor
159 worker_ = std::make_shared<std::thread>(&Executor::WorkerLoop, this); in Executor()
162 Executor::~Executor() { in ~Executor()
166 MS_LOG(ERROR) << "Executor call destructor failed: " << e.what(); in ~Executor()
168 MS_LOG(ERROR) << "Executor call destructor failed."; in ~Executor()
172 void Executor::WorkerJoin() { in WorkerJoin()
185 void Executor::WorkerLoop() { in WorkerLoop()
228 std::vector<std::shared_ptr<RunGraphTask>> Executor::GetReadyTasksFromPendingList() { in GetReadyTasksFromPendingList()
243 void Executor::OnEvent(const ExecutorEvent &event) { in OnEvent()
[all …]
|
| /third_party/vk-gl-cts/executor/ |
| D | xeBatchExecutor.cpp | 2 * drawElements Quality Program Test Executor
21 * \brief Test batch executor.
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()
[all …]
|
| /third_party/skia/m133/third_party/externals/harfbuzz/.circleci/ |
| D | config.yml | 4 win32-executor:
7 win64-executor:
10 dist-executor:
31 executor: dist-executor
43 executor: dist-executor
132 executor: win32-executor
148 executor: win32-executor
158 executor: win64-executor
174 executor: win64-executor
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/frontend/parallel/ |
| D | group_manager.cc | 100 auto executor = session::ExecutorManager::Instance().GetExecutor(device_name, device_id); in CreateGroupByExecutor() local
101 MS_EXCEPTION_IF_NULL(executor); in CreateGroupByExecutor()
102 return executor->CreateCommGroup(group_name, ranks); in CreateGroupByExecutor()
113 auto executor = session::ExecutorManager::Instance().GetExecutor(device_name, device_id); in DestroyGroupByExecutor() local
114 MS_EXCEPTION_IF_NULL(executor); in DestroyGroupByExecutor()
115 return executor->DestroyCommGroup(group_name); in DestroyGroupByExecutor()
120 // Create group through the executor in CreateGroups()
144 auto executor = session::ExecutorManager::Instance().GetExecutor(device_name, device_id); in CreateGroups() local
145 MS_EXCEPTION_IF_NULL(executor); in CreateGroups()
147 ret = executor->CreateCommGroup(group.first, group.second); in CreateGroups()
[all …]
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/transform/acl_ir/ |
| D | op_api_exec.h | 177 // For normal generate executor.
187 …transform::aclOpExecutor *executor = nullptr; …
190 …transform::aclOpExecutor **executor_addr = &executor; …
192 …return std::make_tuple(workspace_size, executor, release_func); …
211 …return std::make_tuple(workspace_size, executor, release_func); …
215 // For custom generate executor.
233 …transform::aclOpExecutor *executor = nullptr; …
234 …transform::aclOpExecutor **executor_addr = &executor; …
246 …return std::make_tuple(workspace_size, executor, …
252 // For speed up generate executor.
[all …]
|
| /third_party/skia/third_party/externals/harfbuzz/.circleci/ |
| D | config.yml | 4 win32-executor:
7 win64-executor:
10 autotools-executor:
31 executor: autotools-executor
46 executor: autotools-executor
135 executor: win32-executor
148 executor: win32-executor
158 executor: win64-executor
171 executor: win64-executor
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/minddata/dataset/kernels/image/dvpp/utils/ |
| D | dvpp_image_utils.cc | 121 aclOpExecutor *executor; in DvppAdjustBrightness() local
124 &workspace_size, &executor); in DvppAdjustBrightness()
142 workspace_addr, workspace_size, executor, in DvppAdjustBrightness()
145 // use the input to hold the workspace and release it when the executor / npu_map_job finish in DvppAdjustBrightness()
153 nullptr, workspace_size, executor, in DvppAdjustBrightness()
211 aclOpExecutor *executor; in DvppAdjustContrast() local
214 &workspace_size, &executor); in DvppAdjustContrast()
232 workspace_addr, workspace_size, executor, in DvppAdjustContrast()
235 // use the input to hold the workspace and release it when the executor / npu_map_job finish in DvppAdjustContrast()
243 nullptr, workspace_size, executor, in DvppAdjustContrast()
[all …]
|
| /third_party/vk-gl-cts/external/amber/src/src/ |
| D | executor_test.cc | 15 #include "src/executor.h"
240 Executor ex; in TEST_F()
270 Executor ex; in TEST_F()
300 Executor ex; in TEST_F()
327 Executor ex; in TEST_F()
362 Executor ex; in TEST_F()
393 Executor ex; in TEST_F()
414 Executor ex; in TEST_F()
434 Executor ex; in TEST_F()
464 Executor ex; in TEST_F()
[all …]
|
| D | executor.h | 26 /// The executor is responsible for running the given script against an engine.
27 class Executor {
29 /// Create a new executor.
30 Executor();
31 ~Executor();
|
| /third_party/mindspore/mindspore-src/source/mindspore/lite/src/infer/ |
| D | executor.h | 27 class Executor : public std::enable_shared_from_this<Executor> {
29 virtual ~Executor() = default;
31 /// \brief The Name of the Executor.
33 /// \return String name of executor.
48 /// \brief Resize Executor Kernels.
|
| /third_party/mindspore/mindspore-src/source/mindspore/ccsrc/frontend/parallel/parallel_stub/ |
| D | executor_manager_stub.cc | 20 std::shared_ptr<Executor> ExecutorManager::GetExecutor(const std::string &device_name, uint32_t dev… in GetExecutor()
26 auto executor = std::make_shared<Executor>(device_name, device_id); in GetExecutor() local
27 executors_[dev_key] = executor; in GetExecutor()
28 return executor; in GetExecutor()
|
| /third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/lib/Support/ |
| D | Parallel.cpp | 30 class Executor { class
32 virtual ~Executor() = default;
35 static Executor *getDefaultExecutor();
38 /// An implementation of an Executor that runs closures on a thread pool
40 class ThreadPoolExecutor : public Executor {
114 Executor *Executor::getDefaultExecutor() { in getDefaultExecutor()
143 // lock if all threads in the default executor are blocked. To prevent the dead
152 Executor::getDefaultExecutor()->add([&, F] { in spawn()
|