Searched refs:RUNNING (Results 1 - 12 of 12) sorted by relevance
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | state.rs | 20 const RUNNING: usize = 0b0001; consts
80 cur & RUNNING == RUNNING
87 (cur & SCHEDULING != SCHEDULING) && (cur & RUNNING != RUNNING) && (cur & FINISHED != FINISHED)
134 next |= RUNNING;
162 next &= !RUNNING;
191 next &= !RUNNING;
332 RUNNING, SCHEDULING,
382 /// 1. (cur & RUNNING
[all...] |
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| H A D | worker.h | 43 enum class WorkerState { IDLE, RUNNING, BLOCKED };
member in Commonlibrary::Concurrent::TaskPoolModule::WorkerState
103 state_ = WorkerState::RUNNING;
in NotifyTaskRunning()
|
| H A D | task.h | 43 enum ExecuteState { NOT_FOUND, WAITING, RUNNING, CANCELED, FINISHED, DELAYED, ENDING}; enumerator
|
| H A D | task_manager.cpp | 195 if (state == ExecuteState::RUNNING || state == ExecuteState::ENDING) { in GetTaskInfos()
251 !worker->UpdateWorkerState(WorkerState::RUNNING, WorkerState::BLOCKED)) { in CheckForBlockedWorkers()
263 worker->UpdateWorkerState(WorkerState::BLOCKED, WorkerState::RUNNING); in CheckForBlockedWorkers()
1694 group->groupState_ = ExecuteState::RUNNING; in UpdateGroupState()
|
| H A D | taskpool.cpp | 74 napi_value runningState = NapiHelper::CreateUint32(env, ExecuteState::RUNNING);
in InitTaskPool()
78 DECLARE_NAPI_PROPERTY("RUNNING", runningState),
in InitTaskPool()
570 task->taskState_ != ExecuteState::RUNNING && task->taskState_ != ExecuteState::ENDING)) {
in ExecuteTask()
|
| H A D | worker.cpp | 368 // the worker state is still RUNNING and the start time will be updated
in NotifyTaskFinished()
371 UpdateWorkerState(WorkerState::RUNNING, WorkerState::IDLE);
in NotifyTaskFinished()
|
| H A D | task.cpp | 1084 taskState_ = ExecuteState::RUNNING; in UpdateTask()
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/test/ |
| H A D | test_worker.cpp | 601 UpdateWorkerState(worker, Worker::RunnerState::RUNNING); in HostOnErrorInner()
651 UpdateWorkerState(worker, Worker::RunnerState::RUNNING); in TestWorkerOnMessageInner()
930 UpdateWorkerState(worker, Worker::RunnerState::RUNNING); in DebuggerOnPostTask()
1049 UpdateWorkerState(worker, Worker::RunnerState::RUNNING); in HWTEST_F()
1136 UpdateWorkerState(worker, Worker::RunnerState::RUNNING); in HWTEST_F()
1218 worker->UpdateWorkerState(Worker::RunnerState::RUNNING); in HWTEST_F()
1306 UpdateWorkerState(worker, Worker::RunnerState::RUNNING); in HWTEST_F()
1352 UpdateWorkerState(worker, Worker::RunnerState::RUNNING); in HWTEST_F()
1390 UpdateWorkerState(worker, Worker::RunnerState::RUNNING); in HWTEST_F()
1423 UpdateWorkerState(worker, Worker::RunnerState::RUNNING); in HWTEST_F()
[all...] |
| /commonlibrary/ets_utils/js_concurrent_module/worker/ |
| H A D | worker.h | 40 enum RunnerState { STARTING, RUNNING, TERMINATEING, TERMINATED }; enumerator
387 return runnerState_.load(std::memory_order_acquire) <= RUNNING; in IsNotTerminate()
392 return runnerState_.load(std::memory_order_acquire) == RUNNING; in IsRunning()
|
| H A D | worker.cpp | 1317 worker->UpdateWorkerState(RUNNING); in ExecuteInThread()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test.cpp | 205 worker->state_ = WorkerState::RUNNING;
in CheckForBlockedWorkers()
210 worker->state_ = WorkerState::RUNNING;
in CheckForBlockedWorkers()
216 worker->state_ = WorkerState::RUNNING;
in CheckForBlockedWorkers()
240 worker->state_ = WorkerState::RUNNING;
in TriggerShrink()
342 task->taskState_ = ExecuteState::RUNNING;
in CancelTask()
391 worker->state_ = WorkerState::RUNNING;
in EnqueueTaskId()
632 group->groupState_ = ExecuteState::RUNNING;
in CheckTask()
655 task->taskState_ = ExecuteState::RUNNING;
in CancelGroupTask()
706 task->taskState_ = ExecuteState::RUNNING;
in TriggerSeqRunner()
|
| H A D | test_taskpool.cpp | 2697 group->groupState_ = ExecuteState::RUNNING; in HWTEST_F()
|
Completed in 31 milliseconds