| /arkcompiler/ets_runtime/ecmascript/taskpool/ |
| 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()
80 bool Taskpool::IsDaemonThreadOrInThreadPool(std::thread::id id) const in IsDaemonThreadOrInThreadPool()
|
| D | taskpool.h | 27 class PUBLIC_API Taskpool {
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/ |
| D | ets_taskpool.cpp | 20 Taskpool::Taskpool() : taskId_(1) {} in Taskpool() function in ark::ets::Taskpool
22 EtsLong Taskpool::GenerateTaskId() in GenerateTaskId()
27 void Taskpool::TaskSubmitted(EtsLong taskId) in TaskSubmitted()
33 size_t Taskpool::DecrementTaskCounter(EtsLong taskId, PandaUnorderedMap<EtsLong, size_t> &tasks) in DecrementTaskCounter()
44 bool Taskpool::TaskStarted(uint32_t coroutineId, EtsLong taskId) in TaskStarted()
61 bool Taskpool::TaskFinished(uint32_t coroutineId, EtsLong taskId) in TaskFinished()
78 bool Taskpool::CancelTask(EtsLong taskId) in CancelTask()
89 bool Taskpool::IsTaskCanceled(uint32_t coroutineId) const in IsTaskCanceled()
|
| D | ets_taskpool.h | 26 class Taskpool final {
28 NO_COPY_SEMANTIC(Taskpool);
29 NO_MOVE_SEMANTIC(Taskpool);
31 Taskpool();
32 ~Taskpool() = default;
|
| D | ets_vm.h | 274 Taskpool *GetTaskpool() in GetTaskpool()
279 const Taskpool *GetTaskpool() const in GetTaskpool()
400 Taskpool *taskpool_ {nullptr};
|
| /arkcompiler/ets_runtime/ecmascript/tests/ |
| D | gc_taskpool_test.cpp | 69 Taskpool::GetCurrentTaskpool()->PostTask( in HWTEST_F_L0()
82 Taskpool::GetCurrentTaskpool()->PostDelayedTask( in HWTEST_F_L0()
96 Taskpool::GetCurrentTaskpool()->PostDelayedTask( in HWTEST_F_L0()
110 Taskpool::GetCurrentTaskpool()->PostDelayedTask( in HWTEST_F_L0()
115 Taskpool::GetCurrentTaskpool()->PostTask( in HWTEST_F_L0()
127 Taskpool::GetCurrentTaskpool()->PostTask( in HWTEST_F_L0()
131 Taskpool::GetCurrentTaskpool()->PostDelayedTask( in HWTEST_F_L0()
|
| /arkcompiler/ets_runtime/ecmascript/mem/ |
| D | concurrent_sweeper.cpp | 32 Taskpool::GetCurrentTaskpool()->PostTask( in PostTask()
35 Taskpool::GetCurrentTaskpool()->PostTask( in PostTask()
37 Taskpool::GetCurrentTaskpool()->PostTask( in PostTask()
|
| D | stw_young_gc.cpp | 74 …auto totalThreadCount = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum() + 1; // gc thread and… in Mark()
88 Taskpool::GetCurrentTaskpool()->GetTotalThreadNum() + 1); // gc thread and main thread in Sweep()
|
| D | partial_gc.cpp | 46 Taskpool::GetCurrentTaskpool()->SetThreadPriority(PriorityMode::STW); in RunPhases()
66 Taskpool::GetCurrentTaskpool()->SetThreadPriority(PriorityMode::FOREGROUND); in RunPhases()
|
| D | concurrent_marker.h | 51 size_t taskPoolSize = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum(); in TryIncreaseTaskCounts()
|
| D | heap.cpp | 299 uint32_t totalThreadNum = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum(); in PostInitialization()
315 …Taskpool::GetCurrentTaskpool()->PostTask(std::make_unique<ParallelMarkTask>(dThread_->GetThreadId(… in PostGCMarkingTask()
491 Taskpool::GetCurrentTaskpool()->PostTask( in Reclaim()
527 uint32_t totalThreadNum = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum(); in EnableParallelGC()
783 maxEvacuateTaskCount_ = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum(); in Initialize()
801 workManager_ = new WorkManager(this, Taskpool::GetCurrentTaskpool()->GetTotalThreadNum() + 1); in Initialize()
1051 Taskpool::GetCurrentTaskpool()->PostTask( in Resume()
1089 Taskpool::GetCurrentTaskpool()->Destroy(GetJSThread()->GetThreadId()); in DisableParallelGC()
1095 maxEvacuateTaskCount_ = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum(); in EnableParallelGC()
2133 Taskpool::GetCurrentTaskpool()->PostTask( in PostParallelGCTask()
[all …]
|
| D | parallel_evacuator.cpp | 94 Taskpool::GetCurrentTaskpool()->PostTask( in EvacuateSpace()
241 Taskpool::GetCurrentTaskpool()->PostTask( in UpdateReference()
292 auto totalThreadCount = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum() + 1; in UpdateRecordWeakReference()
366 auto totalThreadCount = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum() + 1; in UpdateRecordWeakReferenceOpt()
|
| D | parallel_evacuator-inl.h | 385 Taskpool::GetCurrentTaskpool()->GetTotalThreadNum()); in CalculateEvacuationThreadNum()
395 Taskpool::GetCurrentTaskpool()->GetTotalThreadNum()); in CalculateUpdateThreadNum()
|
| D | full_gc.cpp | 117 totalThreadCount += Taskpool::GetCurrentTaskpool()->GetTotalThreadNum(); in Sweep()
|
| /arkcompiler/ets_runtime/ecmascript/jit/ |
| 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/ |
| D | shared_concurrent_sweeper.cpp | 31 Taskpool::GetCurrentTaskpool()->PostTask( in PostTask()
34 Taskpool::GetCurrentTaskpool()->PostTask( in PostTask()
|
| D | shared_gc.cpp | 133 auto totalThreadCount = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum() + 1; in UpdateRecordWeakReference()
|
| D | shared_full_gc.cpp | 142 auto totalThreadCount = Taskpool::GetCurrentTaskpool()->GetTotalThreadNum() + 1; in UpdateRecordWeakReference()
|
| /arkcompiler/ets_runtime/ecmascript/daemon/ |
| D | daemon_thread.cpp | 54 Taskpool::GetCurrentTaskpool()->Initialize(); in StartRunning()
81 Taskpool::GetCurrentTaskpool()->Destroy(GetThreadId()); in WaitFinished()
|
| /arkcompiler/ets_runtime/ecmascript/pgo_profiler/ |
| 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, GLOB… in PostResetOutPathTask()
|
| /arkcompiler/ets_runtime/ecmascript/ |
| D | ecma_vm.cpp | 129 Taskpool::GetCurrentTaskpool()->Initialize(); in PostFork()
257 Taskpool::GetCurrentTaskpool()->Initialize(); in Initialize()
341 Taskpool::GetCurrentTaskpool()->Destroy(thread_->GetThreadId()); in ~EcmaVM()
460 if (!Taskpool::GetCurrentTaskpool()->IsDaemonThreadOrInThreadPool(std::this_thread::get_id()) && in CheckThread()
|
| 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/ |
| 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/ |
| D | libark_jsruntime.map | 13 vtable?for?panda::ecmascript::Taskpool;
100 panda::ecmascript::Taskpool::*;
|
| /arkcompiler/ets_runtime/ecmascript/module/ |
| D | module_logger.cpp | 266 Taskpool::GetCurrentTaskpool()->PostTask( in PostModuleLoggerTask()
|