Lines Matching refs:Worker

34 Worker::PriorityScope::PriorityScope(Worker* worker, Priority taskPriority) : worker_(worker)

51 Worker::RunningScope::~RunningScope()

61 Worker* Worker::WorkerConstructor(napi_env env)

64     Worker* worker = new Worker(env);

69 void Worker::CloseHandles()

84 void Worker::ReleaseWorkerHandles(const uv_async_t* req)

86     auto worker = static_cast<Worker*>(req->data);

105 bool Worker::CheckFreeConditions()

133 void Worker::StartExecuteInThread()

146 void Worker::HandleDebuggerTask(const uv_async_t* req)

148     Worker* worker = reinterpret_cast<Worker*>(req->data);

160 void Worker::DebuggerOnPostTask(std::function<void()>&& task)

172 void Worker::InitFfrtInfo()

187 void Worker::InitLoopHandleNum()

201 bool Worker::IsLoopActive()

212 uint64_t Worker::GetWaitTime()

218 void Worker::ExecuteInThread(const void* data)

221     auto worker = reinterpret_cast<Worker*>(const_cast<void*>(data));

231         workerEngine->InitTaskPoolThread(worker->workerEnv_, Worker::TaskResultCallback);

242     ConcurrentHelper::UvHandleInit(loop, worker->performTaskSignal_, Worker::PerformTask, worker);

243     ConcurrentHelper::UvHandleInit(loop, worker->clearWorkerSignal_, Worker::ReleaseWorkerHandles, worker);

244     ConcurrentHelper::UvHandleInit(loop, worker->triggerGCCheckSignal_, Worker::TriggerGCCheck, worker);

249     ConcurrentHelper::UvHandleInit(loop, worker->debuggerOnPostTaskSignal_, Worker::HandleDebuggerTask, worker);

260         HILOG_ERROR("taskpool:: Worker PrepareForWorkerInstance fail");

269 bool Worker::PrepareForWorkerInstance()

279         HILOG_ERROR("taskpool:: Worker CallInitWorkerFunc fail");

287         HILOG_ERROR("taskpool:: Worker construction occur exception");

293 void Worker::ReleaseWorkerThreadContent()

321 void Worker::NotifyExecuteTask()

328 void Worker::NotifyIdle()

333 void Worker::NotifyWorkerCreated()

338 void Worker::NotifyTaskBegin()

344 void Worker::TriggerGCCheck(const uv_async_t* req)

350     auto worker = reinterpret_cast<Worker*>(req->data);

355 void Worker::NotifyTaskFinished()

376 bool Worker::UpdateWorkerState(WorkerState expect, WorkerState desired)

381 void Worker::PerformTask(const uv_async_t* req)

384     auto worker = static_cast<Worker*>(req->data);

457 void Worker::NotifyTaskResult(napi_env env, Task* task, napi_value result)

479 void Worker::NotifyHandleTaskResult(Task* task)

484     Worker* worker = reinterpret_cast<Worker*>(task->worker_);

503 void Worker::TaskResultCallback(napi_env env, napi_value result, bool success, void* data)

520     auto worker = static_cast<Worker*>(task->worker_);

534 void Worker::ResetWorkerPriority()

550 void Worker::StoreTaskId(uint64_t taskId)

556 bool Worker::InitTaskPoolFunc(napi_env env, napi_value func, Task* task)

580 void Worker::UpdateExecutedInfo()

590 void Worker::TerminateTask(uint64_t taskId)

601 void Worker::UpdateLongTaskInfo(Task* task)

611 bool Worker::IsExecutingLongTask()

616 bool Worker::HasLongTask()

621 void Worker::HandleFunctionException(napi_env env, Task* task)

636 void Worker::PostReleaseSignal()