common/thread_worker: Fix data race

This commit is contained in:
FernandoS27 2021-04-06 04:23:02 +02:00 committed by ReinUsesLisp
parent bf5b5c1bf4
commit a10e112e64
2 changed files with 18 additions and 1 deletions

View file

@ -11,6 +11,7 @@
#include <vector>
#include <queue>
#include "common/common_types.h"
#include "common/unique_function.h"
namespace Common {
@ -29,6 +30,10 @@ private:
std::condition_variable condition;
std::condition_variable wait_condition;
std::atomic_bool stop{};
std::atomic<u64> work_scheduled{};
std::atomic<u64> work_done{};
std::atomic<u64> workers_stopped{};
std::atomic<u64> workers_queued{};
};
} // namespace Common