This commit is contained in:
Cam K 2021-04-21 19:20:00 -04:00
commit 7ee86a5d40
2 changed files with 18 additions and 2 deletions

View File

@ -48,13 +48,19 @@ void ConfigManager::save(bool lock) {
void ConfigManager::enableAutoSave() {
if (!autoSaveEnabled) {
autoSaveEnabled = true;
termFlag = false;
autoSaveThread = std::thread(autoSaveWorker, this);
}
}
void ConfigManager::disableAutoSave() {
if (autoSaveEnabled) {
autoSaveEnabled = false;
{
std::lock_guard<std::mutex> lock(termMtx);
autoSaveEnabled = false;
termFlag = true;
termCond.notify_one();
}
autoSaveThread.join();
}
}
@ -80,6 +86,11 @@ void ConfigManager::autoSaveWorker(ConfigManager* _this) {
_this->save(false);
}
_this->mtx.unlock();
std::this_thread::sleep_for(std::chrono::milliseconds(1000));
// Sleep but listen for wakeup call
{
std::unique_lock<std::mutex> lock(_this->termMtx);
_this->termCond.wait_for(lock, std::chrono::milliseconds(1000), [_this]() { return _this->termFlag; } );
}
}
}

View File

@ -3,6 +3,7 @@
#include <thread>
#include <string>
#include <mutex>
#include <condition_variable>
using nlohmann::json;
@ -29,4 +30,8 @@ private:
std::thread autoSaveThread;
std::mutex mtx;
std::mutex termMtx;
std::condition_variable termCond;
bool termFlag = false;
};