| /arkcompiler/ets_runtime/ecmascript/taskpool/ |
| H A D | taskpool.cpp | 21 Taskpool *Taskpool::GetCurrentTaskpool() in GetCurrentTaskpool()
23 static Taskpool *taskpool = new Taskpool(); in GetCurrentTaskpool()
27 void Taskpool::Initialize(int threadNum, in Initialize()
37 void Taskpool::Destroy(int32_t id) in Destroy()
52 void Taskpool::TerminateTask(int32_t id, TaskType type) in TerminateTask()
60 uint32_t Taskpool::TheMostSuitableThreadNum(uint32_t threadNum) const in TheMostSuitableThreadNum()
72 void Taskpool::ForEachTask(const std::function<void(Task*)> &f) in ForEachTask()
|
| H A D | taskpool.h | 27 class PUBLIC_API Taskpool { class
29 PUBLIC_API static Taskpool *GetCurrentTaskpool();
31 Taskpool() = default;
32 PUBLIC_API ~Taskpool() in ~Taskpool()
39 NO_COPY_SEMANTIC(Taskpool);
40 NO_MOVE_SEMANTIC(Taskpool);
|
| /arkcompiler/runtime_core/static_core/plugins/ets/runtime/ |
| H A D | ets_taskpool.cpp | 20 Taskpool::Taskpool() : taskId_(1), taskGroupId_(1) {} in Taskpool() function in ark::ets::Taskpool
22 EtsLong Taskpool::GenerateTaskId() in GenerateTaskId()
27 EtsLong Taskpool::GenerateTaskGroupId() in GenerateTaskGroupId()
32 EtsLong Taskpool::GenerateSeqRunnerId() in GenerateSeqRunnerId()
37 void Taskpool::TaskSubmitted(EtsLong taskId) in TaskSubmitted()
43 void Taskpool::GroupSubmitted(EtsLong groupId, size_t tasksCount) in GroupSubmitted()
50 size_t Taskpool::DecrementTaskCounter(EtsLong id, PandaUnorderedMap<EtsLong, size_t> &tasks) in DecrementTaskCounter()
61 bool Taskpool::MoveTaskFromWaitingToRunning(EtsLong id, PandaUnorderedMap<EtsLong, size_t> &waitingTasks, in MoveTaskFromWaitingToRunning()
76 bool Taskpool
[all...] |
| H A D | ets_taskpool.h | 25 /// @class Taskpool contains information about each common task passed to execution until the task will not be finished
26 class Taskpool final {
28 NO_COPY_SEMANTIC(Taskpool);
29 NO_MOVE_SEMANTIC(Taskpool);
31 Taskpool();
32 ~Taskpool() = default;
|
| H A D | ets_vm.h | 275 Taskpool *GetTaskpool() in GetTaskpool()
280 const Taskpool *GetTaskpool() const in GetTaskpool()
424 Taskpool *taskpool_ {nullptr};
|
| H A D | ets_vm.cpp | 176 taskpool_ = allocator->New<Taskpool>();
|
| /arkcompiler/ets_runtime/ecmascript/mem/ |
| H A D | concurrent_sweeper.cpp | 32 Taskpool::GetCurrentTaskpool()->PostTask( in PostTask()
35 Taskpool::GetCurrentTaskpool()->PostTask( in PostTask()
37 Taskpool::GetCurrentTaskpool()->PostTask( in PostTask()
|
| H A D | partial_gc.cpp | 46 Taskpool::GetCurrentTaskpool()->SetThreadPriority(PriorityMode::STW); in RunPhases()
66 Taskpool::GetCurrentTaskpool()->SetThreadPriority(PriorityMode::FOREGROUND); in RunPhases()
|
| H A D | heap.cpp | 296 uint32_t totalThreadNum = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum(); in PostInitialization()
312 Taskpool::GetCurrentTaskpool()->PostTask(std::make_unique<ParallelMarkTask>(dThread_->GetThreadId(), in PostGCMarkingTask()
504 Taskpool::GetCurrentTaskpool()->PostTask( in Reclaim()
540 uint32_t totalThreadNum = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum(); in EnableParallelGC()
755 maxEvacuateTaskCount_ = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum(); in Initialize()
773 workManager_ = new WorkManager(this, Taskpool::GetCurrentTaskpool()->GetTotalThreadNum() + 1); in Initialize()
1011 Taskpool::GetCurrentTaskpool()->PostTask( in Resume()
1048 Taskpool::GetCurrentTaskpool()->Destroy(GetJSThread()->GetThreadId()); in DisableParallelGC()
1054 maxEvacuateTaskCount_ = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum(); in EnableParallelGC()
2136 Taskpool in PostParallelGCTask()
[all...] |
| H A D | concurrent_marker.h | 51 size_t taskPoolSize = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum(); in TryIncreaseTaskCounts()
|
| H A D | parallel_evacuator.cpp | 100 Taskpool::GetCurrentTaskpool()->PostTask( in EvacuateSpace()
141 auto totalThreadCount = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum() + 1; in UpdateRecordWeakReferenceInParallel()
279 Taskpool::GetCurrentTaskpool()->PostTask( in UpdateReference()
330 auto totalThreadCount = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum() + 1; in UpdateRecordWeakReference()
|
| H A D | parallel_evacuator-inl.h | 394 Taskpool::GetCurrentTaskpool()->GetTotalThreadNum()); in CalculateEvacuationThreadNum()
404 Taskpool::GetCurrentTaskpool()->GetTotalThreadNum()); in CalculateUpdateThreadNum()
|
| H A D | full_gc.cpp | 117 totalThreadCount += Taskpool::GetCurrentTaskpool()->GetTotalThreadNum(); in Sweep()
|
| /arkcompiler/ets_runtime/ecmascript/jit/ |
| H A D | jit_task.h | 40 class JitTaskpool : public Taskpool {
70 Taskpool::Initialize(0, [needInitJitFort](os::thread::native_handle_type thread) { in Initialize()
87 Taskpool::Destroy(threadId_); in Destroy()
|
| /arkcompiler/ets_runtime/ecmascript/mem/shared_heap/ |
| H A D | shared_concurrent_sweeper.cpp | 31 Taskpool::GetCurrentTaskpool()->PostTask( in PostTask()
34 Taskpool::GetCurrentTaskpool()->PostTask( in PostTask()
|
| H A D | shared_full_gc.cpp | 129 auto totalThreadCount = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum() + 1; in UpdateRecordWeakReference()
|
| H A D | shared_gc.cpp | 133 auto totalThreadCount = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum() + 1; in UpdateRecordWeakReference()
|
| /arkcompiler/ets_runtime/ecmascript/daemon/ |
| H A D | daemon_thread.cpp | 54 Taskpool::GetCurrentTaskpool()->Initialize(); in StartRunning()
81 Taskpool::GetCurrentTaskpool()->Destroy(GetThreadId()); in WaitFinished()
|
| /arkcompiler/ets_runtime/ecmascript/pgo_profiler/ |
| H A D | pgo_profiler_encoder.cpp | 309 Taskpool::GetCurrentTaskpool()->TerminateTask(GLOBAL_TASK_ID, TaskType::PGO_SAVE_TASK); in TerminateSaveTask()
317 Taskpool::GetCurrentTaskpool()->PostTask(std::make_unique<SaveTask>(this, GLOBAL_TASK_ID)); in PostSaveTask()
331 Taskpool::GetCurrentTaskpool()->PostTask(std::make_unique<ResetOutPathTask>(this, moduleName, GLOBAL_TASK_ID)); in PostResetOutPathTask()
|
| H A D | pgo_profiler.cpp | 413 Taskpool::GetCurrentTaskpool()->PostTask( in DispatchPGODumpTask()
|
| /arkcompiler/ets_runtime/ecmascript/ |
| H A D | ecma_vm.cpp | 132 Taskpool::GetCurrentTaskpool()->Initialize(); in PostFork()
265 Taskpool::GetCurrentTaskpool()->Initialize(); in Initialize()
349 Taskpool::GetCurrentTaskpool()->Destroy(thread_->GetThreadId()); in ~EcmaVM()
468 if (!Taskpool::GetCurrentTaskpool()->IsDaemonThreadOrInThreadPool(std::this_thread::get_id()) && in CheckThread()
|
| H A D | ecma_string_table.cpp | 25 const uint32_t postTaskCount = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum(); in PostSweepWeakRefTask()
27 Taskpool::GetCurrentTaskpool()->PostTask(std::make_unique<SweepWeakRefTask>(iter_, this, visitor)); in PostSweepWeakRefTask()
|
| /arkcompiler/ets_runtime/ecmascript/jspandafile/ |
| H A D | js_pandafile.cpp | 499 Taskpool::GetCurrentTaskpool()->PostTask( in PostInitializeMethodTask()
540 for (uint32_t i = 0; i < Taskpool::GetCurrentTaskpool()->GetTotalThreadNum(); i++) { in TranslateClasses()
|
| /arkcompiler/ets_runtime/ecmascript/module/ |
| H A D | module_logger.cpp | 266 Taskpool::GetCurrentTaskpool()->PostTask( in PostModuleLoggerTask()
|