| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | parker.rs | 34 const IDLE: usize = 0; consts
43 state: AtomicUsize::new(IDLE),
79 .compare_exchange(NOTIFIED, IDLE, SeqCst, SeqCst) in park()
102 .compare_exchange(IDLE, PARKED_ON_DRIVER, SeqCst, SeqCst) in park_on_driver()
106 self.state.swap(IDLE, SeqCst); in park_on_driver()
114 match self.state.swap(IDLE, SeqCst) { in park_on_driver()
127 .compare_exchange(IDLE, PARKED_ON_CONDVAR, SeqCst, SeqCst) in park_on_condvar_timeout()
132 self.state.swap(IDLE, SeqCst); in park_on_condvar_timeout()
150 .compare_exchange(NOTIFIED, IDLE, SeqCst, SeqCst) in park_on_condvar_timeout()
158 self.state.store(IDLE, SeqCs in park_on_condvar_timeout()
[all...] |
| H A D | current_thread.rs | 30 const IDLE: usize = 0; consts
90 state: AtomicUsize::new(IDLE), in new()
113 .compare_exchange(IDLE, PARKED_ON_DRIVER, AcqRel, Acquire) in park_on_driver()
117 return match self.state.swap(IDLE, AcqRel) { in park_on_driver()
134 match self.state.swap(IDLE, AcqRel) { in park_on_driver()
146 .compare_exchange(IDLE, PARKED_ON_CONDVAR, AcqRel, Acquire) in park_on_condvar()
150 return match self.state.swap(IDLE, AcqRel) { in park_on_condvar()
166 match self.state.swap(IDLE, AcqRel) { in park_on_condvar()
176 IDLE | NOTIFIED | NOTIFIED_BLOCK => {} in unpark()
188 IDLE | NOTIFIE in unpark()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | atomic_waker.rs | 26 const IDLE: u8 = 0; consts
37 state: AtomicU8::new(IDLE),
45 .compare_exchange(IDLE, REGISTERING, Acquire, Acquire)
47 Ok(IDLE) => {
52 .compare_exchange(REGISTERING, IDLE, AcqRel, Acquire)
57 self.state.store(IDLE, Release);
78 IDLE => {
|
| /commonlibrary/ets_utils/platform/ |
| H A D | utils.h | 25 IDLE, enumerator
|
| /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
47 {Priority::IDLE, ffrt::qos_background},
214 std::atomic<WorkerState> state_ {WorkerState::IDLE};
|
| H A D | task_manager.cpp | 59 {Priority::IDLE, OHOS::AppExecFwk::EventQueue::Priority::IDLE},
249 if ((worker->state_ == WorkerState::IDLE) || (worker->IsExecutingLongTask()) || in CheckForBlockedWorkers()
261 worker->UpdateWorkerState(WorkerState::BLOCKED, WorkerState::IDLE); in CheckForBlockedWorkers()
411 if (worker->state_ != WorkerState::IDLE || worker->HasLongTask()) { in TriggerShrink()
720 if (priority != Priority::IDLE) { in IncreaseNumIfNoIdle()
727 if (priority != Priority::IDLE) { in DecreaseNumIfNoIdle()
787 auto& idleTaskQueue = taskQueues_[Priority::IDLE]; in DequeueTaskId()
789 return GetTaskByPriority(idleTaskQueue, Priority::IDLE); in DequeueTaskId()
798 if (worker->state_ == WorkerState::IDLE) { in IsChooseIdle()
[all...] |
| H A D | worker.cpp | 176 {ffrt::qos_background, Priority::IDLE},
in InitFfrtInfo()
371 UpdateWorkerState(WorkerState::RUNNING, WorkerState::IDLE);
in NotifyTaskFinished()
|
| H A D | taskpool.cpp | 62 napi_value idlePriority = NapiHelper::CreateUint32(env, Priority::IDLE);
in InitTaskPool()
67 DECLARE_NAPI_PROPERTY("IDLE", idlePriority),
in InitTaskPool()
|
| /commonlibrary/ets_utils/platform/ohos/ |
| H A D | qos_helper.cpp | 31 {Priority::IDLE, OHOS::QOS::QosLevel::QOS_BACKGROUND},
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| H A D | test.cpp | 247 worker->state_ = WorkerState::IDLE;
in TriggerShrink()
255 worker->state_ = WorkerState::IDLE;
in TriggerShrink()
373 worker->state_ = WorkerState::IDLE;
in NotifyWorkerIdle()
430 worker->state_ = WorkerState::IDLE;
in RestoreWorker()
788 worker->state_ = WorkerState::IDLE;
in DebuggerOnPostTask()
870 worker->state_ = WorkerState::IDLE;
in TaskResultCallback()
|
| H A D | test_taskpool.cpp | 826 taskManager.EnqueueTaskId(taskId, Priority::IDLE); in HWTEST_F()
831 ASSERT_TRUE(result.second == Priority::IDLE); in HWTEST_F()
|