| /third_party/mindspore/mindspore/core/mindrt/src/thread/ |
| D | threadpool.cc | 133 for (auto &worker : workers_) { in ~ThreadPool()
137 workers_.clear(); in ~ThreadPool()
159 CPU_SET(core_list[workers_.size() % core_list.size()], &mask); in CreateThreads()
164 workers_.push_back(worker); in CreateThreads()
221 int num = static_cast<int>(workers_.size()) - 1; in DistributeTask()
227 if (workers_[i]->available()) { in DistributeTask()
228 assigned.push_back(workers_[i]); in DistributeTask()
229 sum_frequency += workers_[i]->frequency(); in DistributeTask()
279 for (auto &worker : workers_) { in ActiveWorkers()
285 for (const auto &worker : workers_) { in CurrentWorker()
[all …]
|
| D | actor_threadpool.cc | 88 for (auto &worker : workers_) { in ~ActorThreadPool()
94 for (auto &worker : workers_) { in ~ActorThreadPool()
98 workers_.clear(); in ~ActorThreadPool()
134 auto worker = reinterpret_cast<ActorWorker *>(workers_[i]); in PushActorToQueue()
166 CPU_SET(core_list[workers_.size() % core_list.size()], &mask); in CreateThreads()
171 workers_.push_back(worker); in CreateThreads()
|
| D | threadpool.h | 118 size_t thread_num() const { return workers_.size(); } in thread_num()
151 std::vector<Worker *> workers_; variable
|
| /third_party/node/src/inspector/ |
| D | worker_agent.cc | 36 : workers_(workers) {} in AgentWorkerInspectorDelegate()
42 workers_->WorkerCreated(title, url, waiting, target); in WorkerCreated()
46 std::shared_ptr<NodeWorkers> workers_; member in node::inspector::protocol::__anon30fb8dd00111::AgentWorkerInspectorDelegate
53 : id_(id), workers_(workers) {} in ParentInspectorSessionDelegate()
56 workers_->Detached(id_); in ~ParentInspectorSessionDelegate()
61 workers_->Send(id_, message); in SendMessageToFrontend()
66 std::shared_ptr<NodeWorkers> workers_; member in node::inspector::protocol::__anon30fb8dd00111::ParentInspectorSessionDelegate
89 workers_ = in Wire()
95 workers_->Receive(sessionId, message); in sendMessageToWorker()
106 new AgentWorkerInspectorDelegate(workers_)); in enable()
[all …]
|
| D | worker_agent.h | 34 std::shared_ptr<NodeWorkers> workers_; variable
|
| /third_party/nghttp2/src/ |
| D | shrpx_connection_handler.cc | 167 workers_.clear(); in ~ConnectionHandler()
176 for (auto &worker : workers_) { in set_ticket_keys_to_worker()
186 for (auto &worker : workers_) { in worker_reopen_log_files()
198 for (auto &worker : workers_) { in worker_replace_downstream()
253 assert(workers_.size() == 0); in create_worker_thread()
309 workers_.push_back(std::move(worker)); in create_worker_thread()
312 LLOG(NOTICE, this) << "Created worker thread #" << workers_.size() - 1; in create_worker_thread()
315 for (auto &worker : workers_) { in create_worker_thread()
330 << workers_.size(); in join_worker()
333 for (auto &worker : workers_) { in join_worker()
[all …]
|
| D | shrpx_connection_handler.h | 197 std::vector<std::unique_ptr<Worker>> workers_; variable
|
| D | HttpServer.cc | 1840 workers_.push_back(std::move(worker)); in AcceptHandler()
1851 auto &worker = workers_[next_worker_]; in accept_connection()
1865 std::vector<std::unique_ptr<Worker>> workers_; member in nghttp2::AcceptHandler
|
| /third_party/grpc/src/core/lib/iomgr/poller/ |
| D | eventmanager_libuv.cc | 37 workers_.emplace_back( in LibuvEventManager()
41 workers_.back().Start(); in LibuvEventManager()
47 for (auto& th : workers_) { in ~LibuvEventManager()
|
| D | eventmanager_libuv.h | 79 std::vector<grpc_core::Thread> workers_; variable
|
| /third_party/flutter/engine/flutter/fml/ |
| D | concurrent_message_loop.cc | 23 workers_.emplace_back([i, this]() { in ConcurrentMessageLoop()
33 for (auto& worker : workers_) { in ~ConcurrentMessageLoop()
|
| D | concurrent_message_loop.h | 38 std::vector<std::thread> workers_; variable
|