Lines Matching refs:runningState_
25 TaskThread::TaskThread(std::string_view name) : name_(name), runningState_(RunningState::STOPPED), loop_(nullptr)
39 runningState_ = RunningState::STOPPED;
53 if (runningState_.load() == RunningState::STOPPING) {
54 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; });
56 if (runningState_.load() == RunningState::STOPPED) {
65 runningState_ = RunningState::STARTED;
76 AVCODEC_LOGD("task %{public}s stop entered, current state: %{public}d", name_.data(), runningState_.load());
78 if (runningState_.load() != RunningState::STOPPED) {
79 runningState_ = RunningState::STOPPING;
81 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; });
96 if (runningState_.load() != RunningState::STOPPING && runningState_.load() != RunningState::STOPPED) {
97 runningState_ = RunningState::STOPPING;
106 switch (runningState_.load()) {
108 runningState_ = RunningState::PAUSING;
110 return runningState_.load() == RunningState::PAUSED || runningState_.load() == RunningState::STOPPED;
115 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; });
119 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::PAUSED; });
132 if (runningState_.load() == RunningState::STARTED) {
133 runningState_ = RunningState::PAUSING;
157 name_.data(), runningState_.load());
158 if (runningState_.load() == RunningState::STARTED) {
162 if (runningState_.load() == RunningState::PAUSING || runningState_.load() == RunningState::PAUSED) {
163 runningState_ = RunningState::PAUSED;
167 [this] { return runningState_.load() != RunningState::PAUSED; });
169 if (runningState_.load() == RunningState::STOPPING || runningState_.load() == RunningState::STOPPED) {
170 runningState_ = RunningState::STOPPED;