fix race conditions, add -fsanitize=thread -g to discover them

Author: ahmedakef

main.cpp

@@ -6,10 +6,11 @@
 #include "utils/utils.hpp"
 #include <fcntl.h>
 #include <boost/program_options.hpp>
+#include <atomic>
 namespace po = boost::program_options;
 
 using namespace std;
-bool continue_reading = true;
+atomic<bool> continue_reading = {true};
 
 void handle_printing(Summarizer *summarizer, int delay, int precision)
 {

modules/summarizer.cpp

@@ -12,11 +12,15 @@ Summarizer::Summarizer() : acc(tag::extended_p_square::probabilities = probs) {}
 
 void Summarizer::add_number(double number)
 {
+    std::lock_guard<std::mutex> lock(this->lock);
+
     acc(number);
 }
 
 void Summarizer::print_summary(int precision)
 {
+    std::lock_guard<std::mutex> lock(this->lock);
+
     double count_v = count(acc);
     if (count_v == 0.0){
         print_elements(std::vector<double>{0, 0, 0, 0, 0, 0}, precision);

modules/summarizer.hpp

@@ -1,5 +1,6 @@
 #ifndef Summarizer_H
 #define Summarizer_H
+#include <mutex>
 #include <boost/accumulators/accumulators.hpp>
 #include <boost/accumulators/statistics/stats.hpp>
 #include <boost/accumulators/statistics/count.hpp>
@@ -15,6 +16,8 @@ typedef accumulator_set<double, stats<tag::count, tag::mean, tag::min, tag::max,
 class Summarizer
 {
   accumulator_t acc;
+  std::mutex lock;
+
 
 public:
   Summarizer();