ThreadSafeOutputFileStream.h

Go to the documentation of this file.

#ifndef FWCore_Concurrency_ThreadSafeOutputFileStream_h
#define FWCore_Concurrency_ThreadSafeOutputFileStream_h
 
#include "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};
    tbb::concurrent_queue<std::string> waitingMessages_{};
  };
}  // namespace edm
 
#endif