Lines Matching refs:RunningState
25 TaskThread::TaskThread(std::string_view name) : name_(name), runningState_(RunningState::STOPPED), … in TaskThread()
39 runningState_ = RunningState::STOPPED; in ~TaskThread()
53 if (runningState_.load() == RunningState::STOPPING) { in Start()
54 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Start()
56 if (runningState_.load() == RunningState::STOPPED) { in Start()
65 runningState_ = RunningState::STARTED; in Start()
78 if (runningState_.load() != RunningState::STOPPED) { in Stop()
79 runningState_ = RunningState::STOPPING; in Stop()
81 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Stop()
96 …if (runningState_.load() != RunningState::STOPPING && runningState_.load() != RunningState::STOPPE… in StopAsync()
97 runningState_ = RunningState::STOPPING; in StopAsync()
107 case RunningState::STARTED: { in Pause()
108 runningState_ = RunningState::PAUSING; in Pause()
110 …return runningState_.load() == RunningState::PAUSED || runningState_.load() == RunningState::STOPP… in Pause()
114 case RunningState::STOPPING: { in Pause()
115 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::STOPPED; }); in Pause()
118 case RunningState::PAUSING: { in Pause()
119 syncCond_.wait(lock, [this] { return runningState_.load() == RunningState::PAUSED; }); in Pause()
132 if (runningState_.load() == RunningState::STARTED) { in PauseAsync()
133 runningState_ = RunningState::PAUSING; in PauseAsync()
158 if (runningState_.load() == RunningState::STARTED) { in Run()
162 …if (runningState_.load() == RunningState::PAUSING || runningState_.load() == RunningState::PAUSED)… in Run()
163 runningState_ = RunningState::PAUSED; in Run()
167 [this] { return runningState_.load() != RunningState::PAUSED; }); in Run()
169 …if (runningState_.load() == RunningState::STOPPING || runningState_.load() == RunningState::STOPPE… in Run()
170 runningState_ = RunningState::STOPPED; in Run()