| /arkcompiler/runtime_core/static_core/libpandabase/taskmanager/ |
| H A D | task_scheduler.cpp | 94 for (auto *worker : workers_) { in Initialize()
95 worker->RegisterAllWorkersInLocalQueue(workers_); in Initialize()
97 // Start worker loop executing in Initialize()
98 for (auto *worker : workers_) { in Initialize()
99 worker->Start(); in Initialize()
114 // If worker was successfully found, steals task from its local queue in StealTaskFromOtherWorker()
120 bool TaskScheduler::FillWithTasks(WorkerThread *worker) in FillWithTasks() argument
137 PutTasksInWorker(worker, selectedQueue); in FillWithTasks()
140 // Wait list have task that should be added in queues. So worker firstly should add this task in local queue in FillWithTasks()
161 size_t TaskScheduler::PutTasksInWorker(WorkerThread *worker, TaskQueueI argument
[all...] |
| H A D | worker_thread.cpp | 68 // Worker will steal tasks only if all queues are empty and it's possible to find worker for stealing in WorkerLoop()
134 for (auto *worker : workers) { in RegisterAllWorkersInLocalQueue()
135 if (worker == this) { in RegisterAllWorkersInLocalQueue()
138 perWorkerPopId_[worker] = localQueue_.RegisterConsumer(); in RegisterAllWorkersInLocalQueue()
147 size_t WorkerThread::GetLocalWorkerQueuePopId(WorkerThread *worker) const in GetLocalWorkerQueuePopId()
149 return perWorkerPopId_.at(worker); in GetLocalWorkerQueuePopId()
|
| H A D | task_scheduler.h | 47 * @param threadsCount - number of worker that will be created be Task Manager
116 * @brief Fills @arg worker (local queues) with tasks. The number of tasks obtained depends on the max size of the
117 * worker's local queue and the number of workers. The algorithm strives to give the same number of tasks to all
120 * @param worker - pointer on worker that should be fill will tasks.
123 bool FillWithTasks(WorkerThread *worker);
126 * @brief Method steal task from worker with the largest number of tasks and push it to gotten worker.
127 * @param worker: pointer to WorkerThread that should be fill with stollen task
134 /// @brief Checks if worker loca
[all...] |
| H A D | worker_thread.h | 39 /// @brief functor that should add task in worker
60 /// @brief Waits for worker finish
72 * @brief method returns id of worker to pop tasks.
73 * @param worker: pointer on WorkerThread which id you want to get. It should be added with
76 size_t GetLocalWorkerQueuePopId(WorkerThread *worker) const;
92 * @param id: id worker got after registration
175 * @brief perWorkerPopId_: is map that uses when one worker wants to pop task from other worker's local queue.
|
| /arkcompiler/runtime_core/static_core/runtime/ |
| H A D | thread_pool.h | 171 LOG(FATAL, RUNTIME) << "Cannot initialize worker thread"; in Help()
187 LOG(FATAL, RUNTIME) << "Cannot destroy worker thread"; in Help()
256 LOG(FATAL, RUNTIME) << "Cannot initialize worker thread"; in WorkerEntry()
277 LOG(FATAL, RUNTIME) << "Cannot destroy worker thread"; in WorkerEntry()
325 for (auto worker : workers_) { in REQUIRES()
326 StopWorker(worker); in REQUIRES()
339 void StopWorker(std::thread *worker, size_t threadId = 0) REQUIRES(scaleLock_) in REQUIRES()
341 if (worker != nullptr) { in REQUIRES()
347 worker->join(); in REQUIRES()
348 allocator_->Delete(worker); in REQUIRES()
360 auto worker = allocator_->New<std::thread>(WorkerEntry, this, proc, i); REQUIRES() local
[all...] |
| /arkcompiler/runtime_core/static_core/runtime/coroutines/ |
| H A D | stackful_coroutine_manager.cpp | 49 "[main] worker 0", stackful_coroutines::MAIN_WORKER_ID); in CreateWorkers()
59 runtime, vm, this, StackfulCoroutineWorker::ScheduleLoopType::THREAD, "worker " + ToPandaString(i), i); in CreateWorkers()
414 // currently this function does only the initial worker appointment in ChooseWorkerForCoroutine()
419 LOG(DEBUG, COROUTINES) << "Choosing worker for coro " << co->GetName() << " with affinity mask = " << affinityBits; in ChooseWorkerForCoroutine()
421 // choosing the least loaded worker from the allowed worker set in ChooseWorkerForCoroutine()
441 LOG(DEBUG, COROUTINES) << "Chose worker: " << (*wIt)->GetName(); in ChooseWorkerForCoroutine()
522 for (auto *worker : workers_) { in DumpCoroutineStats()
523 worker->GetPerfStats().Disable(); in DumpCoroutineStats()
524 wstats.push_back(&worker in DumpCoroutineStats()
616 auto *worker = co->GetContext<StackfulCoroutineContext>()->GetWorker(); IsMainWorker() local
[all...] |
| H A D | stackful_coroutine_worker.cpp | 34 LOG(DEBUG, COROUTINES) << "Created a coroutine worker instance: id=" << id_ << " name=" << name_; in StackfulCoroutineWorker()
94 // precondition: current coro and finalizee belong to the current worker in RequestFinalization()
189 void StackfulCoroutineWorker::ScheduleLoopProxy(void *worker) in ScheduleLoopProxy() argument
191 static_cast<StackfulCoroutineWorker *>(worker)->ScheduleLoop(); in ScheduleLoopProxy()
245 // precondition: called within the current worker, no cross-worker calls allowed in RequestScheduleImpl()
|
| H A D | stackful_coroutine_worker.h | 30 * Represents a worker thread for stackful coroutines.
41 * @brief The worker constructor. Create the worker and its schedule loop.
44 * @param type defines the schedule loop type for this worker: a separate thread or a coroutine ("FIBER")
50 /// @return false if the worker is stopped and does not schedule anything, otherwise true
57 /// enable or disable the worker
101 * @brief Signal that an event has happened and unblock all the coroutines in the current worker that are waiting
145 static void ScheduleLoopProxy(void *worker);
|
| /arkcompiler/runtime_core/static_core/dprof/daemon/ |
| H A D | main.cpp | 253 Worker worker; in Main() local
254 worker.Start(storage.get()); in Main()
267 worker.EnqueueClientSocket(std::move(clientSock)); in Main()
270 worker.Stop(); in Main()
|
| /arkcompiler/runtime_core/static_core/runtime/mem/gc/g1/ |
| H A D | update_remset_worker.h | 41 /// @brief Create necessary worker structures and start UpdateRemsetWorker
44 /// @brief Stop UpdateRemsetWorker and destroy according worker structures
139 IS_PROCESS_CARD = 0U, ///< Special value for main work (process cards) in update remset worker
140 IS_STOP_WORKER = 1U, ///< Update remset worker is in destroying process
141 IS_PAUSED_BY_GC_THREAD = 1U << 1U, ///< Update remset worker is paused by GCThread
142 IS_INVALIDATE_REGIONS = 1U << 2U, ///< Update remset worker is invalidating regions
173 * (as SuspendWorkerForGCPause/ResumeWorkerAfterGCPause/DestroyWorker/etc), wait and notify this worker.
222 explicit SuspendUpdateRemsetWorkerScope(UpdateRemsetWorker<LanguageConfig> *worker) : worker_(worker) in SuspendUpdateRemsetWorkerScope() argument
|
| /arkcompiler/runtime_core/static_core/verification/verifier/ |
| H A D | verifier.cpp | 47 LOG(ERROR, VERIFIER) << "Failed to set worker thread name " << ss.str(); in Worker()
296 auto *worker = runtime.GetInternalAllocator()->New<std::thread>(Worker, &queue, &lock, i, &result); in RunVerifier() local
297 threads.push_back(worker); in RunVerifier()
|
| /arkcompiler/ets_frontend/es2panda/test/compiler/js/ |
| H A D | cocos_worker_test.js | 109 var s = globalThis.requireNapi("worker") || (isSystemplugin("worker", "ohos") ? globalThis.ohosplugin.worker : isSystemplugin("worker", "system") ? globalThis.systemplugin.worker : void 0);
124 } else console.error("cocos worker: message type unknown");
[all...] |