ThreadSafeOutputFileStream.h

Go to the documentation of this file.

#ifndef FWCore_Concurrency_ThreadSafeOutputFileStream_h
#define FWCore_Concurrency_ThreadSafeOutputFileStream_h

#include "oneapi/tbb/concurrent_queue.h"

#include <atomic>
#include <fstream>
#include <string>

namespace edm {
  class ThreadSafeOutputFileStream {
  public:
    ThreadSafeOutputFileStream(std::string const& name);
    ~ThreadSafeOutputFileStream();

    void write(std::string&& msg);
    explicit operator bool() const { return static_cast<bool>(file_); }

  private:
    std::ofstream file_;
    std::atomic<bool> msgBeingLogged_{false};
    oneapi::tbb::concurrent_queue<std::string> waitingMessages_{};
  };
}  // namespace edm

#endif